Package step.plugins.timeseries

Class TimeSeriesBucketingHandler

java.lang.Object

step.plugins.timeseries.TimeSeriesBucketingHandler

All Implemented Interfaces:

MeasurementHandler

public class TimeSeriesBucketingHandler
extends Object
implements MeasurementHandler

Constructor Summary

Constructors

Constructor	Description
TimeSeriesBucketingHandler(step.core.timeseries.TimeSeriesIngestionPipeline ingestionPipeline, List<String> attributes)

Method Summary

Modifier and Type	Method	Description
void	afterExecutionEnd(ExecutionContext context)
List<String>	getHandledAttributes()
void	ingestExistingMeasurement(Measurement measurement)	This method will handle existing measurements, and will check if it is a gauge or normal measurement
void	initializeExecutionContext(ExecutionEngineContext executionEngineContext, ExecutionContext executionContext)
void	processGauges(List<Measurement> measurements)
void	processMeasurement(Measurement measurement)
void	processMeasurements(List<Measurement> measurements)

Methods inherited from class java.lang.Object

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

Constructor Details

TimeSeriesBucketingHandler

public TimeSeriesBucketingHandler(step.core.timeseries.TimeSeriesIngestionPipeline ingestionPipeline,
 List<String> attributes)

Method Details

initializeExecutionContext

public void initializeExecutionContext(ExecutionEngineContext executionEngineContext,
 ExecutionContext executionContext)

Specified by:

initializeExecutionContext in interface MeasurementHandler

processMeasurements

public void processMeasurements(List<Measurement> measurements)

Specified by:

processMeasurements in interface MeasurementHandler

processMeasurement

public void processMeasurement(Measurement measurement)

processGauges

public void processGauges(List<Measurement> measurements)

Specified by:

processGauges in interface MeasurementHandler

ingestExistingMeasurement

public void ingestExistingMeasurement(Measurement measurement)

This method will handle existing measurements, and will check if it is a gauge or normal measurement

Parameters:

measurement -

afterExecutionEnd

public void afterExecutionEnd(ExecutionContext context)

Specified by:

afterExecutionEnd in interface MeasurementHandler

getHandledAttributes

public List<String> getHandledAttributes()