public class MetricsDAO extends Object
Constructor and Description |
---|
MetricsDAO(com.datastax.driver.core.Session session,
MetricsConfiguration configuration) |
Modifier and Type | Method and Description |
---|---|
void |
deleteMetricsIndexEntries(MetricsTable table,
long timestamp) |
Iterable<AggregateSimpleNumericMetric> |
findAggregatedSimpleOneHourMetric(int scheduleId,
long startTime,
long endTime) |
RawNumericMetric |
findLatestRawMetric(int scheduleId) |
Iterable<MetricsIndexEntry> |
findMetricsIndexEntries(MetricsTable table,
long timestamp) |
Iterable<AggregateNumericMetric> |
findOneHourMetrics(int scheduleId,
long startTime,
long endTime) |
Iterable<AggregateNumericMetric> |
findOneHourMetrics(List<Integer> scheduleIds,
long startTime,
long endTime) |
Iterable<RawNumericMetric> |
findRawMetrics(int scheduleId,
long startTime,
long endTime) |
Iterable<RawNumericMetric> |
findRawMetrics(List<Integer> scheduleIds,
long startTime,
long endTime) |
com.datastax.driver.core.ResultSetFuture |
findRawMetricsAsync(int scheduleId,
long startTime,
long endTime) |
Iterable<AggregateNumericMetric> |
findSixHourMetrics(int scheduleId,
long startTime,
long endTime) |
Iterable<AggregateNumericMetric> |
findSixHourMetrics(List<Integer> scheduleIds,
long startTime,
long endTime) |
Iterable<AggregateNumericMetric> |
findTwentyFourHourMetrics(int scheduleId,
long startTime,
long endTime) |
Iterable<AggregateNumericMetric> |
findTwentyFourHourMetrics(List<Integer> scheduleIds,
long startTime,
long endTime) |
void |
initPreparedStatements() |
List<MetricResultFuture<AggregateNumericMetric>> |
insertAggregatesAsync(MetricsTable table,
List<AggregateNumericMetric> metrics,
int ttl) |
com.datastax.driver.core.ResultSet |
insertOneHourData(int scheduleId,
long timestamp,
AggregateType type,
double value) |
com.datastax.driver.core.ResultSetFuture |
insertRawData(org.rhq.core.domain.measurement.MeasurementDataNumeric data) |
List<MetricResultFuture<org.rhq.core.domain.measurement.MeasurementDataNumeric>> |
insertRawMetricsAsync(Set<org.rhq.core.domain.measurement.MeasurementDataNumeric> dataSet,
int ttl) |
com.datastax.driver.core.ResultSet |
insertSixHourData(int scheduleId,
long timestamp,
AggregateType type,
double value) |
com.datastax.driver.core.ResultSet |
insertTwentyFourHourData(int scheduleId,
long timestamp,
AggregateType type,
double value) |
com.datastax.driver.core.ResultSet |
setFindTimeSliceForIndex(MetricsTable table,
long timestamp) |
com.datastax.driver.core.ResultSetFuture |
updateMetricsIndex(MetricsTable table,
int scheduleId,
long timestamp) |
void |
updateMetricsIndex(MetricsTable table,
Map<Integer,Long> updates) |
public MetricsDAO(com.datastax.driver.core.Session session, MetricsConfiguration configuration)
public void initPreparedStatements()
public com.datastax.driver.core.ResultSetFuture insertRawData(org.rhq.core.domain.measurement.MeasurementDataNumeric data)
public List<MetricResultFuture<org.rhq.core.domain.measurement.MeasurementDataNumeric>> insertRawMetricsAsync(Set<org.rhq.core.domain.measurement.MeasurementDataNumeric> dataSet, int ttl)
public com.datastax.driver.core.ResultSet insertOneHourData(int scheduleId, long timestamp, AggregateType type, double value)
public com.datastax.driver.core.ResultSet insertSixHourData(int scheduleId, long timestamp, AggregateType type, double value)
public com.datastax.driver.core.ResultSet insertTwentyFourHourData(int scheduleId, long timestamp, AggregateType type, double value)
public List<MetricResultFuture<AggregateNumericMetric>> insertAggregatesAsync(MetricsTable table, List<AggregateNumericMetric> metrics, int ttl)
public Iterable<RawNumericMetric> findRawMetrics(int scheduleId, long startTime, long endTime)
public com.datastax.driver.core.ResultSetFuture findRawMetricsAsync(int scheduleId, long startTime, long endTime)
public RawNumericMetric findLatestRawMetric(int scheduleId)
public Iterable<RawNumericMetric> findRawMetrics(List<Integer> scheduleIds, long startTime, long endTime)
public Iterable<AggregateNumericMetric> findOneHourMetrics(int scheduleId, long startTime, long endTime)
public Iterable<AggregateNumericMetric> findSixHourMetrics(int scheduleId, long startTime, long endTime)
public Iterable<AggregateNumericMetric> findTwentyFourHourMetrics(int scheduleId, long startTime, long endTime)
public Iterable<AggregateSimpleNumericMetric> findAggregatedSimpleOneHourMetric(int scheduleId, long startTime, long endTime)
public Iterable<AggregateNumericMetric> findOneHourMetrics(List<Integer> scheduleIds, long startTime, long endTime)
public Iterable<AggregateNumericMetric> findSixHourMetrics(List<Integer> scheduleIds, long startTime, long endTime)
public Iterable<AggregateNumericMetric> findTwentyFourHourMetrics(List<Integer> scheduleIds, long startTime, long endTime)
public Iterable<MetricsIndexEntry> findMetricsIndexEntries(MetricsTable table, long timestamp)
public com.datastax.driver.core.ResultSet setFindTimeSliceForIndex(MetricsTable table, long timestamp)
public void updateMetricsIndex(MetricsTable table, Map<Integer,Long> updates)
public com.datastax.driver.core.ResultSetFuture updateMetricsIndex(MetricsTable table, int scheduleId, long timestamp)
public void deleteMetricsIndexEntries(MetricsTable table, long timestamp)
Copyright © 2008-2013 Red Hat, Inc.. All Rights Reserved.