Package step.core.timeseries

Class TimeSeriesIngestionPipeline

java.lang.Object

step.core.timeseries.TimeSeriesIngestionPipeline

All Implemented Interfaces:

Closeable, AutoCloseable

public class TimeSeriesIngestionPipeline
extends Object
implements Closeable

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TimeSeriesIngestionPipeline(step.core.collections.Collection<Bucket> collection, long resolutionInMs)
protected	TimeSeriesIngestionPipeline(step.core.collections.Collection<Bucket> collection, long resolutionInMs, long flushingPeriodInMs)

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush()
long	getFlushCount()
void	ingestPoint(Map<String,String> attributes, long timestamp, long value)
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

protected TimeSeriesIngestionPipeline(step.core.collections.Collection<Bucket> collection,
                                      long resolutionInMs)

TimeSeriesIngestionPipeline

protected TimeSeriesIngestionPipeline(step.core.collections.Collection<Bucket> collection,
                                      long resolutionInMs,
                                      long flushingPeriodInMs)

Method Detail

ingestPoint

public void ingestPoint(Map<String,String> attributes,
                        long timestamp,
                        long value)

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

Specified by:

close in interface Closeable