io.druid.query.aggregation

Interface Aggregator

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

ApproximateHistogramAggregator, ApproximateHistogramFoldingAggregator, CardinalityAggregator, CountAggregator, DistinctCountAggregator, DoubleFirstAggregator, DoubleLastAggregator, DoubleMaxAggregator, DoubleMinAggregator, DoublesSketchBuildAggregator, DoublesSketchMergeAggregator, DoublesSketchNoOpAggregator, DoubleSumAggregator, EmptyDistinctCountAggregator, FilteredAggregator, FloatFirstAggregator, FloatLastAggregator, FloatMaxAggregator, FloatMinAggregator, FloatSumAggregator, HistogramAggregator, HyperUniquesAggregator, JavaScriptAggregator, LongFirstAggregator, LongLastAggregator, LongMaxAggregator, LongMinAggregator, LongSumAggregator, NoopAggregator, SketchAggregator, TimestampAggregator, VarianceAggregator, VarianceAggregator.FloatVarianceAggregator, VarianceAggregator.LongVarianceAggregator, VarianceAggregator.ObjectVarianceAggregator

public interface Aggregator
extends Closeable

An Aggregator is an object that can aggregate metrics. Its aggregation-related methods (namely, aggregate() and get()) do not take any arguments as the assumption is that the Aggregator was given something in its constructor that it can use to get at the next bit of data. Thus, an Aggregator can be thought of as a closure over some other thing that is stateful and changes between calls to aggregate(). This is currently (as of this documentation) implemented through the use of ColumnValueSelector objects.

Method Summary

Modifier and Type	Method and Description
void	aggregate()
void	close()
Object	get()
default double	getDouble() The default implementation casts getFloat() to double.
float	getFloat()
long	getLong()

Method Detail

aggregate

void aggregate()

get

@Nullable
Object get()

getFloat

float getFloat()

getLong

long getLong()

getDouble

default double getDouble()

The default implementation casts getFloat() to double. This default method is added to enable smooth backward compatibility, please re-implement it if your aggregators work with numeric double columns.

close

void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable