Package step.core.timeseries

Class TimeSeries

java.lang.Object

step.core.timeseries.TimeSeries

public class TimeSeries
extends Object

Constructor Summary

Constructors

Constructor	Description
TimeSeries(step.core.collections.Collection<Bucket> collection, Set<String> indexedAttributes, Integer timeSeriesResolution)
TimeSeries(step.core.collections.CollectionFactory collectionFactory, String collectionName, Set<String> indexedAttributes, Integer ingestionResolutionPeriod)

Method Summary

Modifier and Type	Method	Description
TimeSeriesAggregationPipeline	getAggregationPipeline()
TimeSeriesIngestionPipeline	newIngestionPipeline()
TimeSeriesIngestionPipeline	newIngestionPipeline(long flushingPeriodInMs)
protected static long	timestampToBucketTimestamp(long timestamp, long resolution)

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeSeries

public TimeSeries(step.core.collections.Collection<Bucket> collection,
                  Set<String> indexedAttributes,
                  Integer timeSeriesResolution)

TimeSeries

public TimeSeries(step.core.collections.CollectionFactory collectionFactory,
                  String collectionName,
                  Set<String> indexedAttributes,
                  Integer ingestionResolutionPeriod)

Method Detail

newIngestionPipeline

public TimeSeriesIngestionPipeline newIngestionPipeline()

newIngestionPipeline

public TimeSeriesIngestionPipeline newIngestionPipeline(long flushingPeriodInMs)

getAggregationPipeline

public TimeSeriesAggregationPipeline getAggregationPipeline()

timestampToBucketTimestamp

protected static long timestampToBucketTimestamp(long timestamp,
                                                 long resolution)