Package step.core.timeseries

Class TimeSeriesAggregationPipeline

java.lang.Object

step.core.timeseries.TimeSeriesAggregationPipeline

public class TimeSeriesAggregationPipeline
extends Object

Constructor Summary

Constructors

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

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeSeriesAggregationPipeline

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

Method Detail

getSourceResolution

protected long getSourceResolution()

newQuery

public TimeSeriesAggregationQuery newQuery()

collect

protected TimeSeriesAggregationResponse collect(TimeSeriesAggregationQuery query)