Uses of Interface
org.apache.druid.query.aggregation.Aggregator

Packages that use Aggregator

Package	Description
org.apache.druid.query.aggregation
org.apache.druid.query.aggregation.any
org.apache.druid.query.aggregation.cardinality
org.apache.druid.query.aggregation.constant
org.apache.druid.query.aggregation.firstlast.first
org.apache.druid.query.aggregation.firstlast.last
org.apache.druid.query.aggregation.hyperloglog
org.apache.druid.query.aggregation.mean
org.apache.druid.query.topn
org.apache.druid.query.topn.types

Uses of Aggregator in org.apache.druid.query.aggregation

Classes in org.apache.druid.query.aggregation that implement Aggregator

Modifier and Type	Class	Description
class	CountAggregator
class	DelegatingAggregator	An Aggregator that delegates everything.
class	DoubleMaxAggregator
class	DoubleMinAggregator
class	DoubleSumAggregator
class	ExpressionLambdaAggregator
class	FilteredAggregator
class	FloatMaxAggregator
class	FloatMinAggregator
class	FloatSumAggregator
class	HistogramAggregator
class	JavaScriptAggregator
class	LongMaxAggregator
class	LongMinAggregator
class	LongSumAggregator
final class	NoopAggregator
final class	NullableNumericAggregator	Null-aware numeric Aggregator.
class	ObjectColumnDoubleAggregatorWrapper	This class can be used to wrap Double Aggregator that consume double type columns to handle Object type.
class	ObjectColumnFloatAggregatorWrapper	This class can be used to wrap Float Aggregator that consume float type columns to handle Object type.
class	ObjectColumnLongAggregatorWrapper	This class can be used to wrap Long Aggregator that consume long type columns to handle Object type.
class	SingleValueAggregator
static class	SuppressedAggregatorFactory.SuppressedAggregator

Fields in org.apache.druid.query.aggregation declared as Aggregator

Modifier and Type	Field	Description
protected Aggregator	DelegatingAggregator.delegate

Methods in org.apache.druid.query.aggregation that return Aggregator

Modifier and Type	Method	Description
protected Aggregator	DoubleMaxAggregatorFactory.buildAggregator(BaseDoubleColumnValueSelector selector)
protected Aggregator	DoubleMinAggregatorFactory.buildAggregator(BaseDoubleColumnValueSelector selector)
protected Aggregator	DoubleSumAggregatorFactory.buildAggregator(BaseDoubleColumnValueSelector selector)
protected Aggregator	FloatMaxAggregatorFactory.buildAggregator(BaseFloatColumnValueSelector selector)
protected Aggregator	FloatMinAggregatorFactory.buildAggregator(BaseFloatColumnValueSelector selector)
protected Aggregator	FloatSumAggregatorFactory.buildAggregator(BaseFloatColumnValueSelector selector)
protected Aggregator	LongMaxAggregatorFactory.buildAggregator(BaseLongColumnValueSelector selector)
protected Aggregator	LongMinAggregatorFactory.buildAggregator(BaseLongColumnValueSelector selector)
protected Aggregator	LongSumAggregatorFactory.buildAggregator(BaseLongColumnValueSelector selector)
protected abstract Aggregator	SimpleDoubleAggregatorFactory.buildAggregator(BaseDoubleColumnValueSelector selector)
protected abstract Aggregator	SimpleFloatAggregatorFactory.buildAggregator(BaseFloatColumnValueSelector selector)
protected abstract Aggregator	SimpleLongAggregatorFactory.buildAggregator(BaseLongColumnValueSelector selector)
abstract Aggregator	AggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	CountAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	ExpressionLambdaAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	FilteredAggregatorFactory.factorize(ColumnSelectorFactory columnSelectorFactory)
Aggregator	GroupingAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	HistogramAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	JavaScriptAggregatorFactory.factorize(ColumnSelectorFactory columnFactory)
final Aggregator	NullableNumericAggregatorFactory.factorize(ColumnSelectorFactory columnSelectorFactory)
protected abstract Aggregator	NullableNumericAggregatorFactory.factorize(ColumnSelectorFactory columnSelectorFactory, T selector)	Creates an Aggregator to aggregate values from several rows, by using the provided selector.
protected Aggregator	SimpleDoubleAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected Aggregator	SimpleFloatAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected Aggregator	SimpleLongAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
Aggregator	SingleValueAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	SuppressedAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	AggregatorAndSize.getAggregator()
Aggregator	SuppressedAggregatorFactory.SuppressedAggregator.getDelegate()

Constructors in org.apache.druid.query.aggregation with parameters of type Aggregator

Modifier	Constructor	Description
	AggregatorAndSize(Aggregator aggregator, long initialSizeBytes)
	FilteredAggregator(ValueMatcher matcher, Aggregator delegate)
	NullableNumericAggregator(Aggregator delegate, BaseNullableColumnValueSelector selector)
	SuppressedAggregator(Aggregator delegate)

Constructor parameters in org.apache.druid.query.aggregation with type arguments of type Aggregator

Modifier	Constructor	Description
	ObjectColumnDoubleAggregatorWrapper(BaseObjectColumnValueSelector selector, Function<BaseDoubleColumnValueSelector,Aggregator> delegateBuilder, double nullValue)
	ObjectColumnFloatAggregatorWrapper(BaseObjectColumnValueSelector selector, Function<BaseFloatColumnValueSelector,Aggregator> delegateBuilder, float nullValue)
	ObjectColumnLongAggregatorWrapper(BaseObjectColumnValueSelector selector, Function<BaseLongColumnValueSelector,Aggregator> delegateBuilder, long nullValue)

Uses of Aggregator in org.apache.druid.query.aggregation.any

Classes in org.apache.druid.query.aggregation.any that implement Aggregator

Modifier and Type	Class	Description
class	DoubleAnyAggregator
class	FloatAnyAggregator
class	LongAnyAggregator
class	NumericAnyAggregator<TSelector extends BaseNullableColumnValueSelector>	Base type for on heap 'any' aggregator for primitive numeric column selectors
class	StringAnyAggregator

Methods in org.apache.druid.query.aggregation.any that return Aggregator

Modifier and Type	Method	Description
Aggregator	DoubleAnyAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	FloatAnyAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	LongAnyAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	StringAnyAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)

Uses of Aggregator in org.apache.druid.query.aggregation.cardinality

Classes in org.apache.druid.query.aggregation.cardinality that implement Aggregator

Modifier and Type	Class	Description
class	CardinalityAggregator

Methods in org.apache.druid.query.aggregation.cardinality that return Aggregator

Modifier and Type	Method	Description
Aggregator	CardinalityAggregatorFactory.factorize(ColumnSelectorFactory columnFactory)

Uses of Aggregator in org.apache.druid.query.aggregation.constant

Classes in org.apache.druid.query.aggregation.constant that implement Aggregator

Modifier and Type	Class	Description
class	LongConstantAggregator	This aggregator is a no-op aggregator with a fixed non-null output value.

Uses of Aggregator in org.apache.druid.query.aggregation.firstlast.first

Classes in org.apache.druid.query.aggregation.firstlast.first that implement Aggregator

Modifier and Type	Class	Description
class	DoubleFirstAggregator
class	FloatFirstAggregator
class	LongFirstAggregator
class	NumericFirstAggregator	Base type for on heap 'first' aggregator for primitive numeric column selectors
class	StringFirstAggregator

Methods in org.apache.druid.query.aggregation.firstlast.first that return Aggregator

Modifier and Type	Method	Description
Aggregator	DoubleFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	FloatFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	LongFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	StringFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)

Uses of Aggregator in org.apache.druid.query.aggregation.firstlast.last

Classes in org.apache.druid.query.aggregation.firstlast.last that implement Aggregator

Modifier and Type	Class	Description
class	DoubleLastAggregator
class	FloatLastAggregator
class	LongLastAggregator
class	NumericLastAggregator	Base type for on heap 'last' aggregator for primitive numeric column selectors..
class	StringLastAggregator

Methods in org.apache.druid.query.aggregation.firstlast.last that return Aggregator

Modifier and Type	Method	Description
Aggregator	DoubleLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	FloatLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	LongLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	StringLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)

Uses of Aggregator in org.apache.druid.query.aggregation.hyperloglog

Classes in org.apache.druid.query.aggregation.hyperloglog that implement Aggregator

Modifier and Type	Class	Description
class	HyperUniquesAggregator

Methods in org.apache.druid.query.aggregation.hyperloglog that return Aggregator

Modifier and Type	Method	Description
Aggregator	HyperUniquesAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)

Uses of Aggregator in org.apache.druid.query.aggregation.mean

Classes in org.apache.druid.query.aggregation.mean that implement Aggregator

Modifier and Type	Class	Description
class	DoubleMeanAggregator

Methods in org.apache.druid.query.aggregation.mean that return Aggregator

Modifier and Type	Method	Description
Aggregator	DoubleMeanAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)

Uses of Aggregator in org.apache.druid.query.topn

Fields in org.apache.druid.query.topn declared as Aggregator

Modifier and Type	Field	Description
static final Aggregator[]	TopNAlgorithm.EMPTY_ARRAY

Methods in org.apache.druid.query.topn that return Aggregator

Modifier and Type	Method	Description
Aggregator[][]	BaseTopNAlgorithm.AggregatorArrayProvider.build()
static Aggregator[]	BaseTopNAlgorithm.makeAggregators(Cursor cursor, List<AggregatorFactory> aggregatorSpecs)
protected Aggregator[][]	HeapBasedTopNAlgorithm.makeDimValSelector(TopNParams params, int numProcessed, int numToProcess)
protected Aggregator[][]	HeapBasedTopNAlgorithm.updateDimValSelector(Aggregator[][] aggregators, int numProcessed, int numToProcess)

Methods in org.apache.druid.query.topn with parameters of type Aggregator

Modifier and Type	Method	Description
protected long	HeapBasedTopNAlgorithm.scanAndAggregate(TopNParams params, Aggregator[][] rowSelector, TopNColumnAggregatesProcessor processor)
protected Aggregator[][]	HeapBasedTopNAlgorithm.updateDimValSelector(Aggregator[][] aggregators, int numProcessed, int numToProcess)
protected void	HeapBasedTopNAlgorithm.updateResults(TopNParams params, Aggregator[][] aggregators, TopNColumnAggregatesProcessor processor, TopNResultBuilder resultBuilder)

Uses of Aggregator in org.apache.druid.query.topn.types

Methods in org.apache.druid.query.topn.types that return Aggregator

Modifier and Type	Method	Description
Aggregator[][]	NullableNumericTopNColumnAggregatesProcessor.getRowSelector(TopNQuery query, TopNParams params, TopNCursorInspector cursorInspector)
Aggregator[][]	StringTopNColumnAggregatesProcessor.getRowSelector(TopNQuery query, TopNParams params, TopNCursorInspector cursorInspector)
Aggregator[][]	TopNColumnAggregatesProcessor.getRowSelector(TopNQuery query, TopNParams params, TopNCursorInspector cursorInspector)	Used by HeapBasedTopNAlgorithm.

Methods in org.apache.druid.query.topn.types with parameters of type Aggregator

Modifier and Type	Method	Description
long	NullableNumericTopNColumnAggregatesProcessor.scanAndAggregate(TopNQuery query, Selector selector, Cursor cursor, CursorGranularizer granularizer, Aggregator[][] rowSelector)
long	StringTopNColumnAggregatesProcessor.scanAndAggregate(TopNQuery query, DimensionSelector selector, Cursor cursor, CursorGranularizer granularizer, Aggregator[][] rowSelector)
long	TopNColumnAggregatesProcessor.scanAndAggregate(TopNQuery query, ValueSelectorType selector, Cursor cursor, CursorGranularizer granularizer, Aggregator[][] rowSelector)	Used by HeapBasedTopNAlgorithm.