net.opentsdb.core

Interface Aggregator

public interface Aggregator

A function capable of aggregating multiple DataPoints together.

All aggregators must be stateless. All they can do is run through a sequence of Longs or Doubles and return an aggregated value.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	Aggregator.Doubles A sequence of doubles.
static interface	Aggregator.Longs A sequence of longs.

Method Summary

Methods

Modifier and Type	Method and Description
Aggregators.Interpolation	interpolationMethod() Returns the interpolation method to use when working with data points across time series.
double	runDouble(Aggregator.Doubles values) Aggregates a sequence of doubles.
long	runLong(Aggregator.Longs values) Aggregates a sequence of longs.

Method Detail

runLong

long runLong(Aggregator.Longs values)

Aggregates a sequence of longs.

Parameters:

values - The sequence to aggregate.

Returns:

The aggregated value.

runDouble

double runDouble(Aggregator.Doubles values)

Aggregates a sequence of doubles.

Parameters:

values - The sequence to aggregate.

Returns:

The aggregated value.

interpolationMethod

Aggregators.Interpolation interpolationMethod()

Returns the interpolation method to use when working with data points across time series.

Returns:

The interpolation method to use