Package step.core.timeseries

Class TimeSeriesIngestionPipeline

java.lang.Object

step.core.timeseries.TimeSeriesIngestionPipeline

All Implemented Interfaces:

AutoCloseable

public class TimeSeriesIngestionPipeline
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
TimeSeriesIngestionPipeline(BucketAccessor bucketAccessor, long resolutionInMs, long flushingPeriodInMs)

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush()
long	getFlushCount()
void	ingestPoint(BucketAttributes attributes, long timestamp, long value)

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeSeriesIngestionPipeline

public TimeSeriesIngestionPipeline(BucketAccessor bucketAccessor,
                                   long resolutionInMs,
                                   long flushingPeriodInMs)

Method Detail

ingestPoint

public void ingestPoint(BucketAttributes attributes,
                        long timestamp,
                        long value)

flush

public void flush()

getFlushCount

public long getFlushCount()

close

public void close()

Specified by:

close in interface AutoCloseable