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

Packages that use AggregatorFactory

Package	Description
io.druid.client.indexing
io.druid.indexer
io.druid.indexing.common.task
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.groupby
io.druid.query.groupby.orderby
io.druid.query.timeseries
io.druid.query.topn
io.druid.segment
io.druid.segment.incremental
io.druid.segment.indexing
io.druid.sql.antlr4

Uses of AggregatorFactory in io.druid.client.indexing

Methods in io.druid.client.indexing that return types with arguments of type AggregatorFactory

Modifier and Type	Method and Description
List<AggregatorFactory>	ClientMergeQuery.getAggregators()

Constructor parameters in io.druid.client.indexing with type arguments of type AggregatorFactory

Constructor and Description
ClientMergeQuery(String dataSource, List<io.druid.timeline.DataSegment> segments, List<AggregatorFactory> aggregators)

Uses of AggregatorFactory in io.druid.indexer

Methods in io.druid.indexer with parameters of type AggregatorFactory

Modifier and Type	Method and Description
static io.druid.data.input.InputRow	InputRowSerde.fromBytes(byte[] data, AggregatorFactory[] aggs)
protected File	LegacyIndexGeneratorJob.LegacyIndexGeneratorReducer.mergeQueryableIndex(List<QueryableIndex> indexes, AggregatorFactory[] aggs, File file, ProgressIndicator progressIndicator)
protected File	IndexGeneratorJob.IndexGeneratorReducer.mergeQueryableIndex(List<QueryableIndex> indexes, AggregatorFactory[] aggs, File file, ProgressIndicator progressIndicator)
static byte[]	InputRowSerde.toBytes(io.druid.data.input.InputRow row, AggregatorFactory[] aggs)

Uses of AggregatorFactory in io.druid.indexing.common.task

Methods in io.druid.indexing.common.task that return types with arguments of type AggregatorFactory

Modifier and Type	Method and Description
List<AggregatorFactory>	MergeTask.getAggregators()

Constructor parameters in io.druid.indexing.common.task with type arguments of type AggregatorFactory

Constructor and Description
MergeTask(String id, String dataSource, List<io.druid.timeline.DataSegment> segments, List<AggregatorFactory> aggregators, IndexSpec indexSpec)

Uses of AggregatorFactory in io.druid.query

Methods in io.druid.query that return types with arguments of type AggregatorFactory

Modifier and Type	Method and Description
List<AggregatorFactory>	Druids.TimeseriesQueryBuilder.getAggregatorSpecs()

Method parameters in io.druid.query with type arguments of type AggregatorFactory

Modifier and Type	Method and Description
Druids.TimeseriesQueryBuilder	Druids.TimeseriesQueryBuilder.aggregators(List<AggregatorFactory> a)
static byte[]	QueryCacheHelper.computeAggregatorBytes(List<AggregatorFactory> aggregatorSpecs)
static int	DruidMetrics.findNumComplexAggs(List<AggregatorFactory> aggs)
static Aggregator[]	QueryRunnerHelper.makeAggregators(Cursor cursor, List<AggregatorFactory> aggregatorSpecs)
static void	Queries.verifyAggregations(List<AggregatorFactory> aggFactories, List<PostAggregator> postAggs)

Uses of AggregatorFactory in io.druid.query.aggregation

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

Modifier and Type	Class and Description
class	CountAggregatorFactory
class	DoubleMaxAggregatorFactory
class	DoubleMinAggregatorFactory
class	DoubleSumAggregatorFactory
class	FilteredAggregatorFactory
class	HistogramAggregatorFactory
class	JavaScriptAggregatorFactory
class	LongMaxAggregatorFactory
class	LongMinAggregatorFactory
class	LongSumAggregatorFactory
class	MaxAggregatorFactory This class can be removed when we dont need "max" aggregator backward compatibility
class	MinAggregatorFactory This class can be removed when we dont need "min" aggregator backward compatibility

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

Modifier and Type	Method and Description
AggregatorFactory	FilteredAggregatorFactory.getAggregator()
AggregatorFactory	LongSumAggregatorFactory.getCombiningFactory()
AggregatorFactory	LongMinAggregatorFactory.getCombiningFactory()
AggregatorFactory	LongMaxAggregatorFactory.getCombiningFactory()
AggregatorFactory	JavaScriptAggregatorFactory.getCombiningFactory()
AggregatorFactory	HistogramAggregatorFactory.getCombiningFactory()
AggregatorFactory	FilteredAggregatorFactory.getCombiningFactory()
AggregatorFactory	DoubleSumAggregatorFactory.getCombiningFactory()
AggregatorFactory	DoubleMinAggregatorFactory.getCombiningFactory()
AggregatorFactory	DoubleMaxAggregatorFactory.getCombiningFactory()
AggregatorFactory	CountAggregatorFactory.getCombiningFactory()
AggregatorFactory	AggregatorFactory.getCombiningFactory() Returns an AggregatorFactory that can be used to combine the output of aggregators from this factory.

Methods in io.druid.query.aggregation that return types with arguments of type AggregatorFactory

Modifier and Type	Method and Description
static com.metamx.common.Pair<List<AggregatorFactory>,List<PostAggregator>>	AggregatorUtil.condensedAggregators(List<AggregatorFactory> aggList, List<PostAggregator> postAggList, String metric)
List<AggregatorFactory>	LongSumAggregatorFactory.getRequiredColumns()
List<AggregatorFactory>	LongMinAggregatorFactory.getRequiredColumns()
List<AggregatorFactory>	LongMaxAggregatorFactory.getRequiredColumns()
List<AggregatorFactory>	JavaScriptAggregatorFactory.getRequiredColumns()
List<AggregatorFactory>	HistogramAggregatorFactory.getRequiredColumns()
List<AggregatorFactory>	FilteredAggregatorFactory.getRequiredColumns()
List<AggregatorFactory>	DoubleSumAggregatorFactory.getRequiredColumns()
List<AggregatorFactory>	DoubleMinAggregatorFactory.getRequiredColumns()
List<AggregatorFactory>	DoubleMaxAggregatorFactory.getRequiredColumns()
List<AggregatorFactory>	CountAggregatorFactory.getRequiredColumns()
List<AggregatorFactory>	AggregatorFactory.getRequiredColumns() Gets a list of all columns that this AggregatorFactory will scan

Methods in io.druid.query.aggregation with parameters of type AggregatorFactory

Modifier and Type	Method and Description
Object	MetricManipulationFn.manipulate(AggregatorFactory factory, Object object)

Method parameters in io.druid.query.aggregation with type arguments of type AggregatorFactory

Modifier and Type	Method and Description
static com.metamx.common.Pair<List<AggregatorFactory>,List<PostAggregator>>	AggregatorUtil.condensedAggregators(List<AggregatorFactory> aggList, List<PostAggregator> postAggList, String metric)

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

Constructor and Description
FilteredAggregatorFactory(AggregatorFactory delegate, DimFilter filter)

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

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

Modifier and Type	Class and Description
class	CardinalityAggregatorFactory

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

Modifier and Type	Method and Description
AggregatorFactory	CardinalityAggregatorFactory.getCombiningFactory()

Methods in io.druid.query.aggregation.cardinality that return types with arguments of type AggregatorFactory

Modifier and Type	Method and Description
List<AggregatorFactory>	CardinalityAggregatorFactory.getRequiredColumns()

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

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

Modifier and Type	Class and Description
class	ApproximateHistogramAggregatorFactory
class	ApproximateHistogramFoldingAggregatorFactory

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

Modifier and Type	Method and Description
AggregatorFactory	ApproximateHistogramFoldingAggregatorFactory.getCombiningFactory()
AggregatorFactory	ApproximateHistogramAggregatorFactory.getCombiningFactory()

Methods in io.druid.query.aggregation.histogram that return types with arguments of type AggregatorFactory

Modifier and Type	Method and Description
List<AggregatorFactory>	ApproximateHistogramAggregatorFactory.getRequiredColumns()

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

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

Modifier and Type	Class and Description
class	HyperUniquesAggregatorFactory

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

Modifier and Type	Method and Description
AggregatorFactory	HyperUniquesAggregatorFactory.getCombiningFactory()

Methods in io.druid.query.aggregation.hyperloglog that return types with arguments of type AggregatorFactory

Modifier and Type	Method and Description
List<AggregatorFactory>	HyperUniquesAggregatorFactory.getRequiredColumns()

Uses of AggregatorFactory in io.druid.query.groupby

Methods in io.druid.query.groupby that return types with arguments of type AggregatorFactory

Modifier and Type	Method and Description
List<AggregatorFactory>	GroupByQuery.getAggregatorSpecs()

Methods in io.druid.query.groupby with parameters of type AggregatorFactory

Modifier and Type	Method and Description
GroupByQuery.Builder	GroupByQuery.Builder.addAggregator(AggregatorFactory aggregator)

Method parameters in io.druid.query.groupby with type arguments of type AggregatorFactory

Modifier and Type	Method and Description
GroupByQuery.Builder	GroupByQuery.Builder.setAggregatorSpecs(List<AggregatorFactory> aggregatorSpecs)

Constructor parameters in io.druid.query.groupby with type arguments of type AggregatorFactory

Constructor and Description
GroupByQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, DimFilter dimFilter, QueryGranularity granularity, List<DimensionSpec> dimensions, List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs, HavingSpec havingSpec, LimitSpec limitSpec, Map<String,Object> context)

Uses of AggregatorFactory in io.druid.query.groupby.orderby

Method parameters in io.druid.query.groupby.orderby with type arguments of type AggregatorFactory

Modifier and Type	Method and Description
com.google.common.base.Function<com.metamx.common.guava.Sequence<io.druid.data.input.Row>,com.metamx.common.guava.Sequence<io.druid.data.input.Row>>	NoopLimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs)
com.google.common.base.Function<com.metamx.common.guava.Sequence<io.druid.data.input.Row>,com.metamx.common.guava.Sequence<io.druid.data.input.Row>>	LimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs)
com.google.common.base.Function<com.metamx.common.guava.Sequence<io.druid.data.input.Row>,com.metamx.common.guava.Sequence<io.druid.data.input.Row>>	DefaultLimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs)

Uses of AggregatorFactory in io.druid.query.timeseries

Methods in io.druid.query.timeseries that return types with arguments of type AggregatorFactory

Modifier and Type	Method and Description
List<AggregatorFactory>	TimeseriesQuery.getAggregatorSpecs()

Constructor parameters in io.druid.query.timeseries with type arguments of type AggregatorFactory

Constructor and Description
TimeseriesBinaryFn(QueryGranularity granularity, List<AggregatorFactory> aggregations)
TimeseriesQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, DimFilter dimFilter, QueryGranularity granularity, List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs, Map<String,Object> context)

Uses of AggregatorFactory in io.druid.query.topn

Methods in io.druid.query.topn that return types with arguments of type AggregatorFactory

Modifier and Type	Method and Description
List<AggregatorFactory>	TopNQueryBuilder.getAggregatorSpecs()
List<AggregatorFactory>	TopNQuery.getAggregatorSpecs()

Method parameters in io.druid.query.topn with type arguments of type AggregatorFactory

Modifier and Type	Method and Description
TopNQueryBuilder	TopNQueryBuilder.aggregators(List<AggregatorFactory> a)
protected static String[]	TopNQueryQueryToolChest.extractFactoryName(List<AggregatorFactory> aggregatorFactories)
Comparator	TopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs)
Comparator	NumericTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs)
Comparator	LexicographicTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs)
Comparator	InvertedTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs)
Comparator	AlphaNumericTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs)
TopNResultBuilder	TopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp, DimensionSpec dimSpec, int threshold, Comparator comparator, List<AggregatorFactory> aggFactories, List<PostAggregator> postAggs)
TopNResultBuilder	NumericTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp, DimensionSpec dimSpec, int threshold, Comparator comparator, List<AggregatorFactory> aggFactories, List<PostAggregator> postAggs)
TopNResultBuilder	LexicographicTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp, DimensionSpec dimSpec, int threshold, Comparator comparator, List<AggregatorFactory> aggFactories, List<PostAggregator> postAggs)
TopNResultBuilder	InvertedTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp, DimensionSpec dimSpec, int threshold, Comparator comparator, List<AggregatorFactory> aggFactories, List<PostAggregator> postAggs)
protected static Aggregator[]	BaseTopNAlgorithm.makeAggregators(Cursor cursor, List<AggregatorFactory> aggregatorSpecs)
protected static BufferAggregator[]	BaseTopNAlgorithm.makeBufferAggregators(Cursor cursor, List<AggregatorFactory> aggregatorSpecs)
void	TopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs)
void	NumericTopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs)
void	LexicographicTopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs)
void	InvertedTopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs)

Constructor parameters in io.druid.query.topn with type arguments of type AggregatorFactory

Constructor and Description
TopNBinaryFn(TopNResultMerger merger, QueryGranularity granularity, DimensionSpec dimSpec, TopNMetricSpec topNMetricSpec, int threshold, List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs)
TopNLexicographicResultBuilder(org.joda.time.DateTime timestamp, DimensionSpec dimSpec, int threshold, String previousStop, Comparator comparator, List<AggregatorFactory> aggFactories)
TopNNumericResultBuilder(org.joda.time.DateTime timestamp, DimensionSpec dimSpec, String metricName, int threshold, Comparator comparator, List<AggregatorFactory> aggFactories, List<PostAggregator> postAggs)
TopNQuery(DataSource dataSource, DimensionSpec dimensionSpec, TopNMetricSpec topNMetricSpec, int threshold, QuerySegmentSpec querySegmentSpec, DimFilter dimFilter, QueryGranularity granularity, List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs, Map<String,Object> context)

Uses of AggregatorFactory in io.druid.segment

Methods in io.druid.segment with parameters of type AggregatorFactory

Modifier and Type	Method and Description
static File	IndexMerger.merge(List<IndexableAdapter> indexes, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec)
static File	IndexMaker.merge(List<IndexableAdapter> adapters, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec)
static File	IndexMerger.merge(List<IndexableAdapter> indexes, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec, ProgressIndicator progress)
static File	IndexMaker.merge(List<IndexableAdapter> adapters, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec, ProgressIndicator progress)
static File	IndexMerger.mergeQueryableIndex(List<QueryableIndex> indexes, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec)
static File	IndexMaker.mergeQueryableIndex(List<QueryableIndex> indexes, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec)
static File	IndexMerger.mergeQueryableIndex(List<QueryableIndex> indexes, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec, ProgressIndicator progress)
static File	IndexMaker.mergeQueryableIndex(List<QueryableIndex> indexes, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec, ProgressIndicator progress)

Uses of AggregatorFactory in io.druid.segment.incremental

Methods in io.druid.segment.incremental that return AggregatorFactory

Modifier and Type	Method and Description
AggregatorFactory[]	IncrementalIndex.getMetricAggs()
AggregatorFactory[]	IncrementalIndexSchema.getMetrics()

Methods in io.druid.segment.incremental with parameters of type AggregatorFactory

Modifier and Type	Method and Description
protected Integer	OnheapIncrementalIndex.addToFacts(AggregatorFactory[] metrics, boolean deserializeComplexMetrics, io.druid.data.input.InputRow row, AtomicInteger numEntries, io.druid.segment.incremental.IncrementalIndex.TimeAndDims key, ThreadLocal<io.druid.data.input.InputRow> rowContainer, com.google.common.base.Supplier<io.druid.data.input.InputRow> rowSupplier)
protected Integer	OffheapIncrementalIndex.addToFacts(AggregatorFactory[] metrics, boolean deserializeComplexMetrics, io.druid.data.input.InputRow row, AtomicInteger numEntries, io.druid.segment.incremental.IncrementalIndex.TimeAndDims key, ThreadLocal<io.druid.data.input.InputRow> rowContainer, com.google.common.base.Supplier<io.druid.data.input.InputRow> rowSupplier)
protected abstract Integer	IncrementalIndex.addToFacts(AggregatorFactory[] metrics, boolean deserializeComplexMetrics, io.druid.data.input.InputRow row, AtomicInteger numEntries, io.druid.segment.incremental.IncrementalIndex.TimeAndDims key, ThreadLocal<io.druid.data.input.InputRow> rowContainer, com.google.common.base.Supplier<io.druid.data.input.InputRow> rowSupplier)
protected Aggregator[]	OnheapIncrementalIndex.initAggs(AggregatorFactory[] metrics, com.google.common.base.Supplier<io.druid.data.input.InputRow> rowSupplier, boolean deserializeComplexMetrics)
protected BufferAggregator[]	OffheapIncrementalIndex.initAggs(AggregatorFactory[] metrics, com.google.common.base.Supplier<io.druid.data.input.InputRow> rowSupplier, boolean deserializeComplexMetrics)
protected abstract AggregatorType[]	IncrementalIndex.initAggs(AggregatorFactory[] metrics, com.google.common.base.Supplier<io.druid.data.input.InputRow> rowSupplier, boolean deserializeComplexMetrics)
static ColumnSelectorFactory	IncrementalIndex.makeColumnSelectorFactory(AggregatorFactory agg, com.google.common.base.Supplier<io.druid.data.input.InputRow> in, boolean deserializeComplexMetrics)
IncrementalIndexSchema.Builder	IncrementalIndexSchema.Builder.withMetrics(AggregatorFactory[] metrics)

Constructors in io.druid.segment.incremental with parameters of type AggregatorFactory

Constructor and Description
IncrementalIndexSchema(long minTimestamp, QueryGranularity gran, io.druid.data.input.impl.DimensionsSpec dimensionsSpec, AggregatorFactory[] metrics)
OffheapIncrementalIndex(long minTimestamp, QueryGranularity gran, AggregatorFactory[] metrics, StupidPool<ByteBuffer> bufferPool, boolean deserializeComplexMetrics, int maxTotalBufferSize)
OnheapIncrementalIndex(long minTimestamp, QueryGranularity gran, AggregatorFactory[] metrics, boolean deserializeComplexMetrics, int maxRowCount)
OnheapIncrementalIndex(long minTimestamp, QueryGranularity gran, AggregatorFactory[] metrics, int maxRowCount)

Uses of AggregatorFactory in io.druid.segment.indexing

Methods in io.druid.segment.indexing that return AggregatorFactory

Modifier and Type	Method and Description
AggregatorFactory[]	DataSchema.getAggregators()

Constructors in io.druid.segment.indexing with parameters of type AggregatorFactory

Constructor and Description
DataSchema(String dataSource, io.druid.data.input.impl.InputRowParser parser, AggregatorFactory[] aggregators, GranularitySpec granularitySpec)

Uses of AggregatorFactory in io.druid.sql.antlr4

Fields in io.druid.sql.antlr4 declared as AggregatorFactory

Modifier and Type	Field and Description
AggregatorFactory	DruidSQLParser.AggregateContext.agg

Fields in io.druid.sql.antlr4 with type parameters of type AggregatorFactory

Modifier and Type	Field and Description
Map<String,AggregatorFactory>	DruidSQLParser.aggregators