Package step.plugins.timeseries

Class TimeSeriesHandler

java.lang.Object

step.plugins.timeseries.TimeSeriesHandler

public class TimeSeriesHandler
extends Object

Constructor Summary

Constructors

Constructor	Description
TimeSeriesHandler(int resolution, List<String> timeSeriesAttributes, step.core.collections.Collection<Measurement> measurementCollection, ExecutionAccessor executionAccessor, step.core.timeseries.TimeSeries timeSeries, step.core.timeseries.aggregation.TimeSeriesAggregationPipeline aggregationPipeline, AsyncTaskManager asyncTaskManager)

Method Summary

Modifier and Type	Method	Description
TimeSeriesAPIResponse	getBuckets(FetchBucketsRequest request)
TimeSeriesAPIResponse	getMeasurements(FetchBucketsRequest request, Collection<String> fields)	This method fetches and group the RAW measurements into a bucket structure.
Set<String>	getMeasurementsAttributes(String oqlFilter)
AsyncTaskStatus<Object>	rebuildTimeSeries(String executionId)
boolean	timeSeriesIsBuilt(String executionId)
OQLVerifyResponse	verifyOql(String oql)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TimeSeriesHandler

public TimeSeriesHandler(int resolution,
 List<String> timeSeriesAttributes,
 step.core.collections.Collection<Measurement> measurementCollection,
 ExecutionAccessor executionAccessor,
 step.core.timeseries.TimeSeries timeSeries,
 step.core.timeseries.aggregation.TimeSeriesAggregationPipeline aggregationPipeline,
 AsyncTaskManager asyncTaskManager)

Method Details

getMeasurements

public TimeSeriesAPIResponse getMeasurements(FetchBucketsRequest request,
 Collection<String> fields)

This method fetches and group the RAW measurements into a bucket structure.

getBuckets

public TimeSeriesAPIResponse getBuckets(FetchBucketsRequest request)

verifyOql

public OQLVerifyResponse verifyOql(String oql)

getMeasurementsAttributes

public Set<String> getMeasurementsAttributes(String oqlFilter)

timeSeriesIsBuilt

public boolean timeSeriesIsBuilt(String executionId)

rebuildTimeSeries

public AsyncTaskStatus<Object> rebuildTimeSeries(String executionId)