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

Packages that use AggregatorFactory

Package	Description
io.druid.benchmark.datagen
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.datasketches.theta
io.druid.query.aggregation.datasketches.theta.oldapi
io.druid.query.aggregation.distinctcount
io.druid.query.aggregation.first
io.druid.query.aggregation.histogram
io.druid.query.aggregation.hyperloglog
io.druid.query.aggregation.last
io.druid.query.aggregation.post
io.druid.query.aggregation.variance
io.druid.query.groupby
io.druid.query.groupby.epinephelinae
io.druid.query.groupby.orderby
io.druid.query.metadata.metadata
io.druid.query.timeseries
io.druid.query.topn
io.druid.segment
io.druid.segment.incremental
io.druid.segment.indexing
io.druid.sql.calcite.aggregation
io.druid.sql.calcite.rel

Uses of AggregatorFactory in io.druid.benchmark.datagen

Methods in io.druid.benchmark.datagen that return AggregatorFactory

Modifier and Type	Method and Description
AggregatorFactory[]	BenchmarkSchemaInfo.getAggsArray()

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

Modifier and Type	Method and Description
List<AggregatorFactory>	BenchmarkSchemaInfo.getAggs()

Constructor parameters in io.druid.benchmark.datagen with type arguments of type AggregatorFactory

Constructor and Description
BenchmarkSchemaInfo(List<BenchmarkColumnSchema> columnSchemas, List<AggregatorFactory> aggs, org.joda.time.Interval dataInterval, boolean withRollup)

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<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 InputRow	InputRowSerde.fromBytes(byte[] data, AggregatorFactory[] aggs)
protected File	IndexGeneratorJob.IndexGeneratorReducer.mergeQueryableIndex(List<QueryableIndex> indexes, AggregatorFactory[] aggs, File file, ProgressIndicator progressIndicator)
static byte[]	InputRowSerde.toBytes(InputRow row, AggregatorFactory[] aggs, boolean reportParseExceptions)

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()
List<AggregatorFactory>	AppendTask.getAggregators()

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

Constructor and Description
AppendTask(String id, String dataSource, List<DataSegment> segments, List<AggregatorFactory> aggregators, IndexSpec indexSpec, Boolean buildV9Directly, Map<String,Object> context)
MergeTask(String id, String dataSource, List<DataSegment> segments, List<AggregatorFactory> aggregators, Boolean rollup, IndexSpec indexSpec, Boolean buildV9Directly, Map<String,Object> context)

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 List<PostAggregator>	Queries.decoratePostAggregators(List<PostAggregator> postAggs, Map<String,AggregatorFactory> aggFactories)
static int	DruidMetrics.findNumComplexAggs(List<AggregatorFactory> aggs)
static List<PostAggregator>	Queries.prepareAggregations(List<AggregatorFactory> aggFactories, List<PostAggregator> postAggs)

Uses of AggregatorFactory in io.druid.query.aggregation

Subclasses of AggregatorFactory in io.druid.query.aggregation

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	TimestampAggregatorFactory
class	TimestampMaxAggregatorFactory
class	TimestampMinAggregatorFactory

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

Modifier and Type	Method and Description
AggregatorFactory	FilteredAggregatorFactory.getAggregator()
AggregatorFactory	TimestampAggregatorFactory.getCombiningFactory()
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()
abstract AggregatorFactory	AggregatorFactory.getCombiningFactory() Returns an AggregatorFactory that can be used to combine the output of aggregators from this factory.
AggregatorFactory	TimestampAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	LongSumAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	LongMinAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	LongMaxAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	JavaScriptAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	DoubleSumAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	DoubleMinAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	DoubleMaxAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	AggregatorFactory.getMergingFactory(AggregatorFactory other) Returns an AggregatorFactory that can be used to merge the output of aggregators from this factory and other factory.
static AggregatorFactory[]	AggregatorFactory.mergeAggregators(List<AggregatorFactory[]> aggregatorsList) Merges the list of AggregatorFactory[] (presumable from metadata of some segments being merged) and returns merged AggregatorFactory[] (for the metadata for merged segment).

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

Modifier and Type	Method and Description
static Pair<List<AggregatorFactory>,List<PostAggregator>>	AggregatorUtil.condensedAggregators(List<AggregatorFactory> aggList, List<PostAggregator> postAggList, String metric)
List<AggregatorFactory>	TimestampAggregatorFactory.getRequiredColumns()
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()
abstract 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
AggregatorFactory	TimestampAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	LongSumAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	LongMinAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	LongMaxAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	JavaScriptAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	DoubleSumAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	DoubleMinAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	DoubleMaxAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	AggregatorFactory.getMergingFactory(AggregatorFactory other) Returns an AggregatorFactory that can be used to merge the output of aggregators from this factory and other factory.
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 Pair<List<AggregatorFactory>,List<PostAggregator>>	AggregatorUtil.condensedAggregators(List<AggregatorFactory> aggList, List<PostAggregator> postAggList, String metric)
PostAggregator	PostAggregator.decorate(Map<String,AggregatorFactory> aggregators) Returns a richer post aggregator which are built from the given aggregators with their names and some accessible environmental variables such as ones in the object scope.

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

Constructor and Description
AggregatorFactoryNotMergeableException(AggregatorFactory af1, AggregatorFactory af2)
FilteredAggregatorFactory(AggregatorFactory delegate, DimFilter filter)

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

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

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()
AggregatorFactory	CardinalityAggregatorFactory.getMergingFactory(AggregatorFactory other)

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()

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

Modifier and Type	Method and Description
AggregatorFactory	CardinalityAggregatorFactory.getMergingFactory(AggregatorFactory other)

Uses of AggregatorFactory in io.druid.query.aggregation.datasketches.theta

Subclasses of AggregatorFactory in io.druid.query.aggregation.datasketches.theta

Modifier and Type	Class and Description
class	SketchAggregatorFactory
class	SketchMergeAggregatorFactory

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

Modifier and Type	Method and Description
AggregatorFactory	SketchMergeAggregatorFactory.getCombiningFactory()
AggregatorFactory	SketchMergeAggregatorFactory.getMergingFactory(AggregatorFactory other)

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

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

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

Modifier and Type	Method and Description
AggregatorFactory	SketchMergeAggregatorFactory.getMergingFactory(AggregatorFactory other)

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

Modifier and Type	Method and Description
PostAggregator	SketchSetPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
PostAggregator	SketchEstimatePostAggregator.decorate(Map<String,AggregatorFactory> aggregators)

Uses of AggregatorFactory in io.druid.query.aggregation.datasketches.theta.oldapi

Subclasses of AggregatorFactory in io.druid.query.aggregation.datasketches.theta.oldapi

Modifier and Type	Class and Description
class	OldSketchBuildAggregatorFactory
class	OldSketchMergeAggregatorFactory

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

Subclasses of AggregatorFactory in io.druid.query.aggregation.distinctcount

Modifier and Type	Class and Description
class	DistinctCountAggregatorFactory

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

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

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

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

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

Subclasses of AggregatorFactory in io.druid.query.aggregation.first

Modifier and Type	Class and Description
class	DoubleFirstAggregatorFactory
class	LongFirstAggregatorFactory

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

Modifier and Type	Method and Description
AggregatorFactory	LongFirstAggregatorFactory.getCombiningFactory()
AggregatorFactory	DoubleFirstAggregatorFactory.getCombiningFactory()
AggregatorFactory	LongFirstAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	DoubleFirstAggregatorFactory.getMergingFactory(AggregatorFactory other)

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

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

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

Modifier and Type	Method and Description
AggregatorFactory	LongFirstAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	DoubleFirstAggregatorFactory.getMergingFactory(AggregatorFactory other)

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

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

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()
AggregatorFactory	ApproximateHistogramAggregatorFactory.getMergingFactory(AggregatorFactory other)

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()

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

Modifier and Type	Method and Description
AggregatorFactory	ApproximateHistogramAggregatorFactory.getMergingFactory(AggregatorFactory other)

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

Modifier and Type	Method and Description
PostAggregator	QuantilesPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
PostAggregator	QuantilePostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
PostAggregator	MinPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
PostAggregator	MaxPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
PostAggregator	EqualBucketsPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
PostAggregator	CustomBucketsPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
PostAggregator	BucketsPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)

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

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

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()
AggregatorFactory	HyperUniquesAggregatorFactory.getMergingFactory(AggregatorFactory other)

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()

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

Modifier and Type	Method and Description
AggregatorFactory	HyperUniquesAggregatorFactory.getMergingFactory(AggregatorFactory other)

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

Modifier and Type	Method and Description
HyperUniqueFinalizingPostAggregator	HyperUniqueFinalizingPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)

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

Subclasses of AggregatorFactory in io.druid.query.aggregation.last

Modifier and Type	Class and Description
class	DoubleLastAggregatorFactory
class	LongLastAggregatorFactory

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

Modifier and Type	Method and Description
AggregatorFactory	LongLastAggregatorFactory.getCombiningFactory()
AggregatorFactory	DoubleLastAggregatorFactory.getCombiningFactory()
AggregatorFactory	LongLastAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	DoubleLastAggregatorFactory.getMergingFactory(AggregatorFactory other)

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

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

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

Modifier and Type	Method and Description
AggregatorFactory	LongLastAggregatorFactory.getMergingFactory(AggregatorFactory other)
AggregatorFactory	DoubleLastAggregatorFactory.getMergingFactory(AggregatorFactory other)

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

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

Modifier and Type	Method and Description
LongLeastPostAggregator	LongLeastPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
LongGreatestPostAggregator	LongGreatestPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
JavaScriptPostAggregator	JavaScriptPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
FinalizingFieldAccessPostAggregator	FinalizingFieldAccessPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
FieldAccessPostAggregator	FieldAccessPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
ExpressionPostAggregator	ExpressionPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
DoubleLeastPostAggregator	DoubleLeastPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
DoubleGreatestPostAggregator	DoubleGreatestPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
ConstantPostAggregator	ConstantPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)
ArithmeticPostAggregator	ArithmeticPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)

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

Subclasses of AggregatorFactory in io.druid.query.aggregation.variance

Modifier and Type	Class and Description
class	VarianceAggregatorFactory
class	VarianceFoldingAggregatorFactory

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

Modifier and Type	Method and Description
AggregatorFactory	VarianceAggregatorFactory.getCombiningFactory()
AggregatorFactory	VarianceAggregatorFactory.getMergingFactory(AggregatorFactory other)

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

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

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

Modifier and Type	Method and Description
AggregatorFactory	VarianceAggregatorFactory.getMergingFactory(AggregatorFactory other)

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

Modifier and Type	Method and Description
PostAggregator	StandardDeviationPostAggregator.decorate(Map<String,AggregatorFactory> aggregators)

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)
GroupByQuery	GroupByQuery.withAggregatorSpecs(List<AggregatorFactory> aggregatorSpecs)

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

Constructor and Description
GroupByQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, VirtualColumns virtualColumns, DimFilter dimFilter, Granularity 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.epinephelinae

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

Modifier and Type

Method and Description

static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Row>>

RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query, boolean isInputRaw, Map<String,ValueType> rawInputRowSignature, GroupByQueryConfig config, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, int concurrencyHint, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, AggregatorFactory[] aggregatorFactories) If isInputRaw is true, transformations such as timestamp truncation and extraction functions have not been applied to the input rows yet, for example, in a nested query, if an extraction function is being applied in the outer query to a field of the inner query.

Constructors in io.druid.query.groupby.epinephelinae with parameters of type AggregatorFactory

Constructor and Description
BufferGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier, Grouper.KeySerde<KeyType> keySerde, ColumnSelectorFactory columnSelectorFactory, AggregatorFactory[] aggregatorFactories, int bufferGrouperMaxSize, float maxLoadFactor, int initialBuckets)
ConcurrentGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier, Grouper.KeySerdeFactory<KeyType> keySerdeFactory, ColumnSelectorFactory columnSelectorFactory, AggregatorFactory[] aggregatorFactories, int bufferGrouperMaxSize, float bufferGrouperMaxLoadFactor, int bufferGrouperInitialBuckets, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, int concurrencyHint)
SpillingGrouper(com.google.common.base.Supplier<ByteBuffer> bufferSupplier, Grouper.KeySerdeFactory<KeyType> keySerdeFactory, ColumnSelectorFactory columnSelectorFactory, AggregatorFactory[] aggregatorFactories, int bufferGrouperMaxSize, float bufferGrouperMaxLoadFactor, int bufferGrouperInitialBuckets, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, boolean spillingAllowed)

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<Sequence<Row>,Sequence<Row>>	NoopLimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs)
com.google.common.base.Function<Sequence<Row>,Sequence<Row>>	LimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs) Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.
com.google.common.base.Function<Sequence<Row>,Sequence<Row>>	DefaultLimitSpec.build(List<DimensionSpec> dimensions, List<AggregatorFactory> aggs, List<PostAggregator> postAggs)

Uses of AggregatorFactory in io.druid.query.metadata.metadata

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

Modifier and Type	Method and Description
Map<String,AggregatorFactory>	SegmentAnalysis.getAggregators()

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

Constructor and Description
SegmentAnalysis(String id, List<org.joda.time.Interval> interval, Map<String,ColumnAnalysis> columns, long size, long numRows, Map<String,AggregatorFactory> aggregators, TimestampSpec timestampSpec, Granularity queryGranularity, Boolean rollup)

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(Granularity granularity, List<AggregatorFactory> aggregations)
TimeseriesQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, boolean descending, VirtualColumns virtualColumns, DimFilter dimFilter, Granularity 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	DimensionTopNMetricSpec.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)
TopNResultBuilder	DimensionTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp, DimensionSpec dimSpec, int threshold, Comparator comparator, List<AggregatorFactory> aggFactories, List<PostAggregator> postAggs)
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)
void	DimensionTopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs)
TopNQuery	TopNQuery.withAggregatorSpecs(List<AggregatorFactory> aggregatorSpecs)

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

Constructor and Description
TopNBinaryFn(TopNResultMerger merger, Granularity 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, VirtualColumns virtualColumns, DimensionSpec dimensionSpec, TopNMetricSpec topNMetricSpec, int threshold, QuerySegmentSpec querySegmentSpec, DimFilter dimFilter, Granularity granularity, List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs, Map<String,Object> context)

Uses of AggregatorFactory in io.druid.segment

Methods in io.druid.segment that return AggregatorFactory

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

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

Modifier and Type	Method and Description
File	IndexMerger.append(List<IndexableAdapter> indexes, AggregatorFactory[] aggregators, File outDir, IndexSpec indexSpec)
File	IndexMerger.append(List<IndexableAdapter> indexes, AggregatorFactory[] aggregators, File outDir, IndexSpec indexSpec, ProgressIndicator progress)
protected File	IndexMergerV9.makeIndexFiles(List<IndexableAdapter> adapters, AggregatorFactory[] metricAggs, File outDir, ProgressIndicator progress, List<String> mergedDimensions, List<String> mergedMetrics, com.google.common.base.Function<ArrayList<Iterable<Rowboat>>,Iterable<Rowboat>> rowMergerFn, IndexSpec indexSpec)
protected File	IndexMerger.makeIndexFiles(List<IndexableAdapter> indexes, AggregatorFactory[] metricAggs, File outDir, ProgressIndicator progress, List<String> mergedDimensions, List<String> mergedMetrics, com.google.common.base.Function<ArrayList<Iterable<Rowboat>>,Iterable<Rowboat>> rowMergerFn, IndexSpec indexSpec)
File	IndexMerger.merge(List<IndexableAdapter> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec)
File	IndexMerger.merge(List<IndexableAdapter> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec, ProgressIndicator progress)
static Metadata	Metadata.merge(List<Metadata> toBeMerged, AggregatorFactory[] overrideMergedAggregators)
File	IndexMerger.mergeQueryableIndex(List<QueryableIndex> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec)
File	IndexMerger.mergeQueryableIndex(List<QueryableIndex> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec, ProgressIndicator progress)
Metadata	Metadata.setAggregators(AggregatorFactory[] aggregators)

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

Constructor and Description
AggFactoryStringIndexed(AggregatorFactory[] metricAggs)
RowboatMergeFunction(AggregatorFactory[] metricAggs)

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, boolean reportParseExceptions, InputRow row, AtomicInteger numEntries, IncrementalIndex.TimeAndDims key, ThreadLocal<InputRow> rowContainer, com.google.common.base.Supplier<InputRow> rowSupplier)
protected Integer	OffheapIncrementalIndex.addToFacts(AggregatorFactory[] metrics, boolean deserializeComplexMetrics, boolean reportParseExceptions, InputRow row, AtomicInteger numEntries, IncrementalIndex.TimeAndDims key, ThreadLocal<InputRow> rowContainer, com.google.common.base.Supplier<InputRow> rowSupplier)
protected abstract Integer	IncrementalIndex.addToFacts(AggregatorFactory[] metrics, boolean deserializeComplexMetrics, boolean reportParseExceptions, InputRow row, AtomicInteger numEntries, IncrementalIndex.TimeAndDims key, ThreadLocal<InputRow> rowContainer, com.google.common.base.Supplier<InputRow> rowSupplier)
protected Aggregator[]	OnheapIncrementalIndex.initAggs(AggregatorFactory[] metrics, com.google.common.base.Supplier<InputRow> rowSupplier, boolean deserializeComplexMetrics)
protected BufferAggregator[]	OffheapIncrementalIndex.initAggs(AggregatorFactory[] metrics, com.google.common.base.Supplier<InputRow> rowSupplier, boolean deserializeComplexMetrics)
protected abstract AggregatorType[]	IncrementalIndex.initAggs(AggregatorFactory[] metrics, com.google.common.base.Supplier<InputRow> rowSupplier, boolean deserializeComplexMetrics)
protected ColumnSelectorFactory	IncrementalIndex.makeColumnSelectorFactory(AggregatorFactory agg, com.google.common.base.Supplier<InputRow> in, boolean deserializeComplexMetrics)
static ColumnSelectorFactory	IncrementalIndex.makeColumnSelectorFactory(VirtualColumns virtualColumns, AggregatorFactory agg, com.google.common.base.Supplier<InputRow> in, boolean deserializeComplexMetrics) Column selector used at ingestion time for inputs to aggregators.
IncrementalIndexSchema.Builder	IncrementalIndexSchema.Builder.withMetrics(AggregatorFactory[] metrics)

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

Constructor and Description
IncrementalIndexSchema(long minTimestamp, TimestampSpec timestampSpec, Granularity gran, VirtualColumns virtualColumns, DimensionsSpec dimensionsSpec, AggregatorFactory[] metrics, boolean rollup)
MetricDesc(int index, AggregatorFactory factory)
OffheapIncrementalIndex(long minTimestamp, Granularity gran, AggregatorFactory[] metrics, int maxRowCount, StupidPool<ByteBuffer> bufferPool)
OffheapIncrementalIndex(long minTimestamp, Granularity gran, boolean rollup, AggregatorFactory[] metrics, int maxRowCount, StupidPool<ByteBuffer> bufferPool)
OnheapIncrementalIndex(long minTimestamp, Granularity gran, AggregatorFactory[] metrics, boolean deserializeComplexMetrics, boolean reportParseExceptions, boolean sortFacts, int maxRowCount)
OnheapIncrementalIndex(long minTimestamp, Granularity gran, AggregatorFactory[] metrics, int maxRowCount)
OnheapIncrementalIndex(long minTimestamp, Granularity gran, boolean rollup, DimensionsSpec dimensionsSpec, 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, Map<String,Object> parser, AggregatorFactory[] aggregators, GranularitySpec granularitySpec, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Uses of AggregatorFactory in io.druid.sql.calcite.aggregation

Methods in io.druid.sql.calcite.aggregation with type parameters of type AggregatorFactory

Modifier and Type	Method and Description
static <T extends AggregatorFactory> boolean	Aggregations.aggregatorMatches(AggregatorFactory factory, DimFilter filter, Class<T> clazz, com.google.common.base.Predicate<T> predicate) Returns true if "factory" is an aggregator factory that either matches "predicate" (if filter is null) or is a filtered aggregator factory whose filter is equal to "filter" and underlying aggregator matches "predicate".

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

Modifier and Type	Method and Description
List<AggregatorFactory>	Aggregation.getAggregatorFactories()

Methods in io.druid.sql.calcite.aggregation with parameters of type AggregatorFactory

Modifier and Type	Method and Description
static <T extends AggregatorFactory> boolean	Aggregations.aggregatorMatches(AggregatorFactory factory, DimFilter filter, Class<T> clazz, com.google.common.base.Predicate<T> predicate) Returns true if "factory" is an aggregator factory that either matches "predicate" (if filter is null) or is a filtered aggregator factory whose filter is equal to "filter" and underlying aggregator matches "predicate".
static Aggregation	Aggregation.create(AggregatorFactory aggregatorFactory)

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

Modifier and Type	Method and Description
static Aggregation	Aggregation.create(List<AggregatorFactory> aggregatorFactories, PostAggregator postAggregator)
static Aggregation	Aggregation.createFinalizable(List<AggregatorFactory> aggregatorFactories, PostAggregator postAggregator, PostAggregatorFactory finalizingPostAggregatorFactory)

Uses of AggregatorFactory in io.druid.sql.calcite.rel

Methods in io.druid.sql.calcite.rel that return types with arguments of type AggregatorFactory

Modifier and Type	Method and Description
List<AggregatorFactory>	Grouping.getAggregatorFactories()