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.cardinality
org.apache.druid.query.aggregation.first
org.apache.druid.query.aggregation.hyperloglog
org.apache.druid.query.aggregation.last
org.apache.druid.query.timeseries
org.apache.druid.query.topn
org.apache.druid.query.topn.types
org.apache.druid.segment.incremental

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

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

Modifier and Type	Class and Description
class	CountAggregator
class	DoubleMaxAggregator
class	DoubleMinAggregator
class	DoubleSumAggregator
class	FilteredAggregator
class	FloatMaxAggregator
class	FloatMinAggregator
class	FloatSumAggregator
class	HistogramAggregator
class	JavaScriptAggregator
class	LongMaxAggregator
class	LongMinAggregator
class	LongSumAggregator
class	NoopAggregator
class	NullableAggregator The result of a NullableAggregator will be null if all the values to be aggregated are null values or no values are aggregated at all.
static class	SuppressedAggregatorFactory.SuppressedAggregator

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

Modifier and Type	Method and Description
Aggregator	SuppressedAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	NullableAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	JavaScriptAggregatorFactory.factorize(ColumnSelectorFactory columnFactory)
Aggregator	HistogramAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	FilteredAggregatorFactory.factorize(ColumnSelectorFactory columnSelectorFactory)
Aggregator	CountAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
abstract Aggregator	AggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
protected Aggregator	DoubleSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseDoubleColumnValueSelector selector)
protected Aggregator	DoubleMinAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseDoubleColumnValueSelector selector)
protected Aggregator	DoubleMaxAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseDoubleColumnValueSelector selector)
protected Aggregator	FloatSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseFloatColumnValueSelector selector)
protected Aggregator	FloatMinAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseFloatColumnValueSelector selector)
protected Aggregator	FloatMaxAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseFloatColumnValueSelector selector)
protected Aggregator	LongSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseLongColumnValueSelector selector)
Aggregator	LongMinAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseLongColumnValueSelector selector)
protected Aggregator	LongMaxAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseLongColumnValueSelector selector)
protected abstract Aggregator	NullableAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, T selector) Creates an Aggregator to aggregate values from several rows, by using the provided selector.
Aggregator	SuppressedAggregatorFactory.SuppressedAggregator.getDelegate()

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

Constructor and Description
FilteredAggregator(ValueMatcher matcher, Aggregator delegate)
NullableAggregator(Aggregator delegate, BaseNullableColumnValueSelector selector)
SuppressedAggregator(Aggregator delegate)

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 and Description
class	CardinalityAggregator

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

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

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

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

Modifier and Type	Class and Description
class	DoubleFirstAggregator
class	FloatFirstAggregator
class	LongFirstAggregator
class	StringFirstAggregator

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

Modifier and Type	Method and Description
Aggregator	StringFirstFoldingAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseObjectColumnValueSelector selector)
Aggregator	StringFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseObjectColumnValueSelector selector)
protected Aggregator	LongFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected Aggregator	FloatFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected Aggregator	DoubleFirstAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)

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 and Description
class	HyperUniquesAggregator

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

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

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

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

Modifier and Type	Class and Description
class	DoubleLastAggregator
class	FloatLastAggregator
class	LongLastAggregator
class	StringLastAggregator

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

Modifier and Type	Method and Description
Aggregator	StringLastFoldingAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseObjectColumnValueSelector selector)
Aggregator	StringLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, BaseObjectColumnValueSelector selector)
protected Aggregator	LongLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected Aggregator	FloatLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)
protected Aggregator	DoubleLastAggregatorFactory.factorize(ColumnSelectorFactory metricFactory, ColumnValueSelector selector)

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

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

Modifier and Type	Method and Description
TimeseriesResultBuilder	TimeseriesResultBuilder.addMetric(String name, Aggregator aggregator)

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

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

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

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

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

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

Modifier and Type	Method and Description
long	DimExtractionTopNAlgorithm.scanAndAggregate(TopNParams params, Aggregator[][] rowSelector, Map<Comparable,Aggregator[]> aggregatesStore)
protected Aggregator[][]	DimExtractionTopNAlgorithm.updateDimValSelector(Aggregator[][] aggregators, int numProcessed, int numToProcess)
protected void	DimExtractionTopNAlgorithm.updateResults(TopNParams params, Aggregator[][] rowSelector, Map<Comparable,Aggregator[]> aggregatesStore, 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 and Description
Aggregator[][]	TopNColumnSelectorStrategy.getDimExtractionRowSelector(TopNQuery query, TopNParams params, StorageAdapter storageAdapter) Used by DimExtractionTopNAlgorithm.
Aggregator[][]	StringTopNColumnSelectorStrategy.getDimExtractionRowSelector(TopNQuery query, TopNParams params, StorageAdapter storageAdapter)
Aggregator[][]	NumericTopNColumnSelectorStrategy.getDimExtractionRowSelector(TopNQuery query, TopNParams params, StorageAdapter storageAdapter)

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

Modifier and Type	Method and Description
long	StringTopNColumnSelectorStrategy.dimExtractionScanAndAggregate(TopNQuery query, DimensionSelector selector, Cursor cursor, Aggregator[][] rowSelector, Map<Comparable<?>,Aggregator[]> aggregatesStore)
long	TopNColumnSelectorStrategy.dimExtractionScanAndAggregate(TopNQuery query, ValueSelectorType selector, Cursor cursor, Aggregator[][] rowSelector, DimExtractionAggregateStoreType aggregatesStore) Used by DimExtractionTopNAlgorithm.

Uses of Aggregator in org.apache.druid.segment.incremental

Methods in org.apache.druid.segment.incremental that return Aggregator

Modifier and Type	Method and Description
protected Aggregator[]	OnheapIncrementalIndex.concurrentGet(int offset)
protected Aggregator[]	OnheapIncrementalIndex.getAggsForRow(int rowOffset)
protected Aggregator[]	OnheapIncrementalIndex.initAggs(AggregatorFactory[] metrics, com.google.common.base.Supplier<InputRow> rowSupplier, boolean deserializeComplexMetrics, boolean concurrentEventAdd)

Methods in org.apache.druid.segment.incremental with parameters of type Aggregator

Modifier and Type	Method and Description
protected void	OnheapIncrementalIndex.concurrentSet(int offset, Aggregator[] value)
protected Object	OnheapIncrementalIndex.getAggVal(Aggregator agg, int rowOffset, int aggPosition)