Package step.core.timeseries.aggregation

Class TimeSeriesAggregationPipeline

java.lang.Object

step.core.timeseries.aggregation.TimeSeriesAggregationPipeline

public class TimeSeriesAggregationPipeline
extends Object

Constructor Summary

Constructors

Constructor	Description
TimeSeriesAggregationPipeline(step.core.collections.Collection<Bucket> collectionDriver, long resolution)

Method Summary

Modifier and Type	Method	Description
protected TimeSeriesAggregationResponse	collect(TimeSeriesAggregationQuery query)
protected long	getSourceResolution()
TimeSeriesAggregationQueryBuilder	newQueryBuilder()

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeSeriesAggregationPipeline

public TimeSeriesAggregationPipeline(step.core.collections.Collection<Bucket> collectionDriver,
                                     long resolution)

Method Detail

getSourceResolution

protected long getSourceResolution()

newQueryBuilder

public TimeSeriesAggregationQueryBuilder newQueryBuilder()

collect

protected TimeSeriesAggregationResponse collect(TimeSeriesAggregationQuery query)