Uses of Interface
io.druid.query.aggregation.Aggregator

Packages that use Aggregator

Package	Description
io.druid.query
io.druid.query.aggregation
io.druid.query.aggregation.cardinality
io.druid.query.aggregation.histogram
io.druid.query.aggregation.hyperloglog
io.druid.query.timeseries
io.druid.query.topn
io.druid.segment.incremental

Uses of Aggregator in io.druid.query

Methods in io.druid.query that return Aggregator

Modifier and Type	Method and Description
static Aggregator[]	QueryRunnerHelper.makeAggregators(Cursor cursor, List<AggregatorFactory> aggregatorSpecs)

Uses of Aggregator in io.druid.query.aggregation

Classes in io.druid.query.aggregation that implement Aggregator

Modifier and Type	Class and Description
class	CountAggregator
class	DoubleMaxAggregator
class	DoubleMinAggregator
class	DoubleSumAggregator
class	FilteredAggregator
class	HistogramAggregator
class	JavaScriptAggregator
class	LongMaxAggregator
class	LongMinAggregator
class	LongSumAggregator

Methods in io.druid.query.aggregation that return Aggregator

Modifier and Type	Method and Description
Aggregator	LongSumAggregator.clone()
Aggregator	LongMinAggregator.clone()
Aggregator	LongMaxAggregator.clone()
Aggregator	DoubleSumAggregator.clone()
Aggregator	DoubleMinAggregator.clone()
Aggregator	DoubleMaxAggregator.clone()
Aggregator	CountAggregator.clone()
Aggregator	LongSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	LongMinAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	LongMaxAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	JavaScriptAggregatorFactory.factorize(ColumnSelectorFactory columnFactory)
Aggregator	HistogramAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	FilteredAggregatorFactory.factorize(ColumnSelectorFactory columnSelectorFactory)
Aggregator	DoubleSumAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	DoubleMinAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	DoubleMaxAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	CountAggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
Aggregator	AggregatorFactory.factorize(ColumnSelectorFactory metricFactory)
static Aggregator	Aggregators.noopAggregator()

Constructors in io.druid.query.aggregation with parameters of type Aggregator

Constructor and Description
FilteredAggregator(ValueMatcher matcher, Aggregator delegate)

Uses of Aggregator in io.druid.query.aggregation.cardinality

Classes in io.druid.query.aggregation.cardinality that implement Aggregator

Modifier and Type	Class and Description
class	CardinalityAggregator

Methods in io.druid.query.aggregation.cardinality that return Aggregator

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

Uses of Aggregator in io.druid.query.aggregation.histogram

Classes in io.druid.query.aggregation.histogram that implement Aggregator

Modifier and Type	Class and Description
class	ApproximateHistogramAggregator
class	ApproximateHistogramFoldingAggregator

Methods in io.druid.query.aggregation.histogram that return Aggregator

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

Uses of Aggregator in io.druid.query.aggregation.hyperloglog

Classes in io.druid.query.aggregation.hyperloglog that implement Aggregator

Modifier and Type	Class and Description
class	HyperUniquesAggregator

Methods in io.druid.query.aggregation.hyperloglog that return Aggregator

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

Uses of Aggregator in io.druid.query.timeseries

Methods in io.druid.query.timeseries with parameters of type Aggregator

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

Uses of Aggregator in io.druid.query.topn

Fields in io.druid.query.topn declared as Aggregator

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

Methods in io.druid.query.topn that return Aggregator

Modifier and Type	Method and Description
Aggregator[][]	BaseTopNAlgorithm.AggregatorArrayProvider.build()
protected 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 io.druid.query.topn with parameters of type Aggregator

Modifier and Type	Method and Description
void	DimExtractionTopNAlgorithm.scanAndAggregate(TopNParams params, Aggregator[][] rowSelector, Map<String,Aggregator[]> aggregatesStore, int numProcessed)
protected Aggregator[][]	DimExtractionTopNAlgorithm.updateDimValSelector(Aggregator[][] aggregators, int numProcessed, int numToProcess)
protected void	DimExtractionTopNAlgorithm.updateResults(TopNParams params, Aggregator[][] rowSelector, Map<String,Aggregator[]> aggregatesStore, TopNResultBuilder resultBuilder)

Uses of Aggregator in io.druid.segment.incremental

Methods in io.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<io.druid.data.input.InputRow> rowSupplier, boolean deserializeComplexMetrics)

Methods in io.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)