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
static step.core.collections.Filter	buildFilter(Map<String,String> attributes, Long from, Long to)
static step.core.collections.Filter	buildFilter(TimeSeriesAggregationQuery query)
TimeSeriesAggregationPipeline	getAggregationPipeline()
TimeSeriesIngestionPipeline	newIngestionPipeline()
TimeSeriesIngestionPipeline	newIngestionPipeline(long flushingPeriodInMs)
void	performHousekeeping(TimeSeriesQuery housekeepingQuery)
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

performHousekeeping

public void performHousekeeping(TimeSeriesQuery housekeepingQuery)

newIngestionPipeline

public TimeSeriesIngestionPipeline newIngestionPipeline()

newIngestionPipeline

public TimeSeriesIngestionPipeline newIngestionPipeline(long flushingPeriodInMs)

getAggregationPipeline

public TimeSeriesAggregationPipeline getAggregationPipeline()

timestampToBucketTimestamp

protected static long timestampToBucketTimestamp(long timestamp,
                                                 long resolution)

buildFilter

public static step.core.collections.Filter buildFilter(Map<String,String> attributes,
                                                       Long from,
                                                       Long to)

buildFilter

public static step.core.collections.Filter buildFilter(TimeSeriesAggregationQuery query)