Uses of Class
org.apache.druid.query.aggregation.AggregatorFactory
Packages that use AggregatorFactory
Package
Description
-
Uses of AggregatorFactory in org.apache.druid.data.input.impl
Methods in org.apache.druid.data.input.impl that return AggregatorFactoryMethods in org.apache.druid.data.input.impl with parameters of type AggregatorFactoryModifier and TypeMethodDescriptionAggregateProjectionSpec.Builder.aggregators(AggregatorFactory... aggregators) Constructors in org.apache.druid.data.input.impl with parameters of type AggregatorFactoryModifierConstructorDescriptionAggregateProjectionSpec(String name, DimFilter filter, VirtualColumns virtualColumns, List<DimensionSchema> groupingColumns, AggregatorFactory[] aggregators) -
Uses of AggregatorFactory in org.apache.druid.query
Methods in org.apache.druid.query with parameters of type AggregatorFactoryModifier and TypeMethodDescriptionDruids.TimeseriesQueryBuilder.aggregators(AggregatorFactory... aggregators) Method parameters in org.apache.druid.query with type arguments of type AggregatorFactoryModifier and TypeMethodDescriptionDruids.TimeseriesQueryBuilder.aggregators(List<AggregatorFactory> a) static List<PostAggregator> Queries.decoratePostAggregators(List<PostAggregator> postAggs, Map<String, AggregatorFactory> aggFactories) static voidCacheStrategy.fetchAggregatorsFromCache(List<AggregatorFactory> aggregators, Iterator<Object> resultIter, boolean isResultLevelCache, CacheStrategy.AddToResultFunction addToResultFunction) Helper function used by TopN, GroupBy, Timeseries queries inCacheStrategy.pullFromCache(boolean).static intDruidMetrics.findNumComplexAggs(List<AggregatorFactory> aggs) static List<PostAggregator> Queries.prepareAggregations(List<AggregatorFactory> aggFactories, List<PostAggregator> postAggs) Deprecated. -
Uses of AggregatorFactory in org.apache.druid.query.aggregation
Subclasses of AggregatorFactory in org.apache.druid.query.aggregationModifier and TypeClassDescriptionclassclassclassclassclassclassclassclassclassclassThis class implementsgroupingfunction to determine the grouping that a row is part of.classclassclassclassclassA null-aware aggregator factory.classAbstract superclass for null-aware numeric aggregators.classThis is an abstract class inherited by variousAggregatorFactoryimplementations that consume double input and produce double output on aggregation.classclassThis is an abstract class inherited by variousAggregatorFactoryimplementations that consume long input and produce long output on aggregation.classThis AggregatorFactory is meant to wrap the subquery used as an expression into a single value and is expected to throw an exception when the subquery results in more than one rowclassThis AggregatorFactory is meant for wrapping delegate aggregators for optimization purposes.Methods in org.apache.druid.query.aggregation that return AggregatorFactoryModifier and TypeMethodDescriptionFilteredAggregatorFactory.getAggregator()abstract AggregatorFactoryAggregatorFactory.getCombiningFactory()Returns an AggregatorFactory that can be used to combine the output of aggregators from this factory.CountAggregatorFactory.getCombiningFactory()DoubleMaxAggregatorFactory.getCombiningFactory()DoubleMinAggregatorFactory.getCombiningFactory()DoubleSumAggregatorFactory.getCombiningFactory()ExpressionLambdaAggregatorFactory.getCombiningFactory()FilteredAggregatorFactory.getCombiningFactory()FloatMaxAggregatorFactory.getCombiningFactory()FloatMinAggregatorFactory.getCombiningFactory()FloatSumAggregatorFactory.getCombiningFactory()GroupingAggregatorFactory.getCombiningFactory()HistogramAggregatorFactory.getCombiningFactory()JavaScriptAggregatorFactory.getCombiningFactory()LongMaxAggregatorFactory.getCombiningFactory()LongMinAggregatorFactory.getCombiningFactory()LongSumAggregatorFactory.getCombiningFactory()SingleValueAggregatorFactory.getCombiningFactory()SuppressedAggregatorFactory.getCombiningFactory()SuppressedAggregatorFactory.getDelegate()AggregatorFactory.getMergingFactory(AggregatorFactory other) Returns an AggregatorFactory that can be used to combine the output of aggregators from this factory and another factory.JavaScriptAggregatorFactory.getMergingFactory(AggregatorFactory other) SimpleDoubleAggregatorFactory.getMergingFactory(AggregatorFactory other) SimpleFloatAggregatorFactory.getMergingFactory(AggregatorFactory other) SimpleLongAggregatorFactory.getMergingFactory(AggregatorFactory other) SuppressedAggregatorFactory.getMergingFactory(AggregatorFactory other) 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).AggregatorFactory.optimizeForSegment(PerSegmentQueryOptimizationContext optimizationContext) Return a potentially optimized form of this AggregatorFactory for per-segment queries.FilteredAggregatorFactory.optimizeForSegment(PerSegmentQueryOptimizationContext optimizationContext) SuppressedAggregatorFactory.optimizeForSegment(PerSegmentQueryOptimizationContext optimizationContext) AggregatorFactory.substituteCombiningFactory(AggregatorFactory preAggregated) Check to see if we can make a 'combining' factory of this aggregator that is suitable to process input from a selector of values produced by the otherAggregatorFactoryrepresenting pre-aggregated data.Used in cases where we want to change the output name of the aggregator to something else.Methods in org.apache.druid.query.aggregation that return types with arguments of type AggregatorFactoryModifier and TypeMethodDescriptionstatic Pair<List<AggregatorFactory>, List<PostAggregator>> AggregatorUtil.condensedAggregators(List<AggregatorFactory> aggList, List<PostAggregator> postAggList, String metric) AggregatorAdapters.factories()Return theAggregatorFactoryobjects that were used to create this object.AggregatorFactory.getRequiredColumns()Deprecated.Methods in org.apache.druid.query.aggregation with parameters of type AggregatorFactoryModifier and TypeMethodDescriptionAggregatorFactory.getMergingFactory(AggregatorFactory other) Returns an AggregatorFactory that can be used to combine the output of aggregators from this factory and another factory.JavaScriptAggregatorFactory.getMergingFactory(AggregatorFactory other) SimpleDoubleAggregatorFactory.getMergingFactory(AggregatorFactory other) SimpleFloatAggregatorFactory.getMergingFactory(AggregatorFactory other) SimpleLongAggregatorFactory.getMergingFactory(AggregatorFactory other) SuppressedAggregatorFactory.getMergingFactory(AggregatorFactory other) MetricManipulationFn.manipulate(AggregatorFactory factory, Object object) AggregatorFactory.substituteCombiningFactory(AggregatorFactory preAggregated) Check to see if we can make a 'combining' factory of this aggregator that is suitable to process input from a selector of values produced by the otherAggregatorFactoryrepresenting pre-aggregated data.Method parameters in org.apache.druid.query.aggregation with type arguments of type AggregatorFactoryModifier and TypeMethodDescriptionstatic Pair<List<AggregatorFactory>, List<PostAggregator>> AggregatorUtil.condensedAggregators(List<AggregatorFactory> aggList, List<PostAggregator> postAggList, String metric) PostAggregator.decorate(Map<String, AggregatorFactory> aggregators) Allows returning an enriched post aggregator, built from contextual information available from the given map ofAggregatorFactorykeyed by their names.static AggregatorAdaptersAggregatorAdapters.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory, List<AggregatorFactory> aggregatorFactories) Create an adapters object based onBufferAggregator.static AggregatorAdaptersAggregatorAdapters.factorizeVector(VectorColumnSelectorFactory columnSelectorFactory, List<AggregatorFactory> aggregatorFactories) Create an adapters object based onVectorAggregator.Constructors in org.apache.druid.query.aggregation with parameters of type AggregatorFactoryModifierConstructorDescriptionFilteredAggregatorFactory(AggregatorFactory delegate, DimFilter filter) FilteredAggregatorFactory(AggregatorFactory delegate, DimFilter dimFilter, String name) SuppressedAggregatorFactory(AggregatorFactory delegate) -
Uses of AggregatorFactory in org.apache.druid.query.aggregation.any
Subclasses of AggregatorFactory in org.apache.druid.query.aggregation.anyModifier and TypeClassDescriptionclassclassclassclassMethods in org.apache.druid.query.aggregation.any that return AggregatorFactoryModifier and TypeMethodDescriptionDoubleAnyAggregatorFactory.getCombiningFactory()FloatAnyAggregatorFactory.getCombiningFactory()LongAnyAggregatorFactory.getCombiningFactory()StringAnyAggregatorFactory.getCombiningFactory() -
Uses of AggregatorFactory in org.apache.druid.query.aggregation.cardinality
Subclasses of AggregatorFactory in org.apache.druid.query.aggregation.cardinalityMethods in org.apache.druid.query.aggregation.cardinality that return AggregatorFactory -
Uses of AggregatorFactory in org.apache.druid.query.aggregation.firstlast.first
Subclasses of AggregatorFactory in org.apache.druid.query.aggregation.firstlast.firstModifier and TypeClassDescriptionclassclassclassclassclassFor backwards compatibility; equivalent to a regular StringFirstAggregatorFactory.Methods in org.apache.druid.query.aggregation.firstlast.first that return AggregatorFactoryModifier and TypeMethodDescriptionDoubleFirstAggregatorFactory.getCombiningFactory()FloatFirstAggregatorFactory.getCombiningFactory()LongFirstAggregatorFactory.getCombiningFactory()StringFirstAggregatorFactory.getCombiningFactory() -
Uses of AggregatorFactory in org.apache.druid.query.aggregation.firstlast.last
Subclasses of AggregatorFactory in org.apache.druid.query.aggregation.firstlast.lastModifier and TypeClassDescriptionclassclassclassclassclassFor backwards compatibility; equivalent to a regular StringLastAggregatorFactory.Methods in org.apache.druid.query.aggregation.firstlast.last that return AggregatorFactoryModifier and TypeMethodDescriptionDoubleLastAggregatorFactory.getCombiningFactory()FloatLastAggregatorFactory.getCombiningFactory()LongLastAggregatorFactory.getCombiningFactory()StringLastAggregatorFactory.getCombiningFactory() -
Uses of AggregatorFactory in org.apache.druid.query.aggregation.hyperloglog
Subclasses of AggregatorFactory in org.apache.druid.query.aggregation.hyperloglogMethods in org.apache.druid.query.aggregation.hyperloglog that return AggregatorFactoryModifier and TypeMethodDescriptionHyperUniquesAggregatorFactory.getCombiningFactory()HyperUniquesAggregatorFactory.getMergingFactory(AggregatorFactory other) Methods in org.apache.druid.query.aggregation.hyperloglog with parameters of type AggregatorFactoryModifier and TypeMethodDescriptionHyperUniquesAggregatorFactory.getMergingFactory(AggregatorFactory other) Method parameters in org.apache.druid.query.aggregation.hyperloglog with type arguments of type AggregatorFactoryModifier and TypeMethodDescriptionHyperUniqueFinalizingPostAggregator.decorate(Map<String, AggregatorFactory> aggregators) -
Uses of AggregatorFactory in org.apache.druid.query.aggregation.mean
Subclasses of AggregatorFactory in org.apache.druid.query.aggregation.meanMethods in org.apache.druid.query.aggregation.mean that return AggregatorFactory -
Uses of AggregatorFactory in org.apache.druid.query.aggregation.post
Method parameters in org.apache.druid.query.aggregation.post with type arguments of type AggregatorFactoryModifier and TypeMethodDescriptionArithmeticPostAggregator.decorate(Map<String, AggregatorFactory> aggregators) ConstantPostAggregator.decorate(Map<String, AggregatorFactory> aggregators) DoubleGreatestPostAggregator.decorate(Map<String, AggregatorFactory> aggregators) DoubleLeastPostAggregator.decorate(Map<String, AggregatorFactory> aggregators) ExpressionPostAggregator.decorate(Map<String, AggregatorFactory> aggregators) FieldAccessPostAggregator.decorate(Map<String, AggregatorFactory> aggregators) FinalizingFieldAccessPostAggregator.decorate(Map<String, AggregatorFactory> aggregators) JavaScriptPostAggregator.decorate(Map<String, AggregatorFactory> aggregators) LongGreatestPostAggregator.decorate(Map<String, AggregatorFactory> aggregators) LongLeastPostAggregator.decorate(Map<String, AggregatorFactory> aggregators) -
Uses of AggregatorFactory in org.apache.druid.query.groupby
Methods in org.apache.druid.query.groupby that return types with arguments of type AggregatorFactoryMethods in org.apache.druid.query.groupby with parameters of type AggregatorFactoryModifier and TypeMethodDescriptionGroupByQuery.Builder.addAggregator(AggregatorFactory aggregator) GroupByQuery.Builder.setAggregatorSpecs(AggregatorFactory... aggregatorSpecs) Method parameters in org.apache.druid.query.groupby with type arguments of type AggregatorFactoryModifier and TypeMethodDescriptionGroupByQuery.Builder.setAggregatorSpecs(List<AggregatorFactory> aggregatorSpecs) GroupByQuery.withAggregatorSpecs(List<AggregatorFactory> aggregatorSpecs) -
Uses of AggregatorFactory in org.apache.druid.query.groupby.epinephelinae
Methods in org.apache.druid.query.groupby.epinephelinae with parameters of type AggregatorFactoryModifier and TypeMethodDescriptionGrouper.KeySerde.bufferComparatorWithAggregators(AggregatorFactory[] aggregatorFactories, int[] aggregatorOffsets) When pushing down limits, it may also be necessary to compare aggregated values along with the key using the bufferComparator.static Grouper.BufferComparatorGrouperBufferComparatorUtils.bufferComparatorWithAggregators(AggregatorFactory[] aggregatorFactories, int[] aggregatorOffsets, DefaultLimitSpec limitSpec, List<DimensionSpec> dimensions, Grouper.BufferComparator[] dimComparators, boolean includeTimestamp, boolean sortByDimsFirst, int keySize) static longBufferArrayGrouper.requiredBufferCapacity(int cardinality, AggregatorFactory[] aggregatorFactories) Computes required buffer capacity for a grouping key of the given cardinaltiy and aggregatorFactories.static <KeyType> intStreamingMergeSortedGrouper.requiredBufferCapacity(Grouper.KeySerde<KeyType> keySerde, AggregatorFactory[] aggregatorFactories) Returns the minimum buffer capacity required for this grouper.Constructors in org.apache.druid.query.groupby.epinephelinae with parameters of type AggregatorFactoryModifierConstructorDescriptionConcurrentGrouper(GroupByQueryConfig groupByQueryConfig, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, ReferenceCountingResourceHolder<ByteBuffer> combineBufferHolder, Grouper.KeySerdeFactory<KeyType> keySerdeFactory, Grouper.KeySerdeFactory<KeyType> combineKeySerdeFactory, ColumnSelectorFactory columnSelectorFactory, AggregatorFactory[] aggregatorFactories, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, int concurrencyHint, DefaultLimitSpec limitSpec, boolean sortHasNonGroupingFields, com.google.common.util.concurrent.ListeningExecutorService executor, int priority, boolean hasQueryTimeout, long queryTimeoutAt, GroupByStatsProvider.PerQueryStats perQueryStats) ParallelCombiner(ReferenceCountingResourceHolder<ByteBuffer> combineBufferHolder, AggregatorFactory[] combiningFactories, Grouper.KeySerdeFactory<KeyType> combineKeySerdeFactory, com.google.common.util.concurrent.ListeningExecutorService executor, boolean sortHasNonGroupingFields, int concurrencyHint, int priority, long queryTimeoutAt, int intermediateCombineDegree) 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, DefaultLimitSpec limitSpec, boolean sortHasNonGroupingFields, int mergeBufferSize, GroupByStatsProvider.PerQueryStats perQueryStats) -
Uses of AggregatorFactory in org.apache.druid.query.groupby.having
Methods in org.apache.druid.query.groupby.having that return types with arguments of type AggregatorFactoryModifier and TypeMethodDescriptionstatic Map<String, AggregatorFactory> HavingSpecUtil.computeAggregatorsMap(List<AggregatorFactory> aggregatorSpecs) Method parameters in org.apache.druid.query.groupby.having with type arguments of type AggregatorFactoryModifier and TypeMethodDescriptionstatic Map<String, AggregatorFactory> HavingSpecUtil.computeAggregatorsMap(List<AggregatorFactory> aggregatorSpecs) -
Uses of AggregatorFactory in org.apache.druid.query.groupby.orderby
Method parameters in org.apache.druid.query.groupby.orderby with type arguments of type AggregatorFactoryModifier and TypeMethodDescriptionstatic intOrderByColumnSpec.getAggIndexForOrderBy(OrderByColumnSpec orderSpec, List<AggregatorFactory> aggregatorFactories) -
Uses of AggregatorFactory in org.apache.druid.query.metadata.metadata
Methods in org.apache.druid.query.metadata.metadata that return types with arguments of type AggregatorFactoryMethods in org.apache.druid.query.metadata.metadata with parameters of type AggregatorFactoryModifier and TypeMethodDescriptionSegmentAnalysis.Builder.aggregator(String name, AggregatorFactory aggregatorFactory) Constructor parameters in org.apache.druid.query.metadata.metadata with type arguments of type AggregatorFactoryModifierConstructorDescriptionSegmentAnalysis(String id, List<org.joda.time.Interval> interval, LinkedHashMap<String, ColumnAnalysis> columns, long size, long numRows, Map<String, AggregatorFactory> aggregators, Map<String, AggregateProjectionMetadata> projections, TimestampSpec timestampSpec, Granularity queryGranularity, Boolean rollup) -
Uses of AggregatorFactory in org.apache.druid.query.operator.window
Methods in org.apache.druid.query.operator.window that return AggregatorFactoryConstructors in org.apache.druid.query.operator.window with parameters of type AggregatorFactoryModifierConstructorDescriptionWindowFramedAggregateProcessor(WindowFrame frame, AggregatorFactory[] aggregations) -
Uses of AggregatorFactory in org.apache.druid.query.rowsandcols.semantic
Methods in org.apache.druid.query.rowsandcols.semantic with parameters of type AggregatorFactoryModifier and TypeMethodDescriptionDefaultFramedOnHeapAggregatable.aggregateAll(WindowFrame frame, AggregatorFactory[] aggFactories) FramedOnHeapAggregatable.aggregateAll(WindowFrame frame, AggregatorFactory[] aggFactories) Aggregates the data according to theWindowFrameusing theAggregatorFactoryobjects provided.static ObjectDefaultFramedOnHeapAggregatable.cloneAggValue(AggregatorFactory aggFactory, Object value) -
Uses of AggregatorFactory in org.apache.druid.query.timeseries
Methods in org.apache.druid.query.timeseries that return types with arguments of type AggregatorFactoryMethod parameters in org.apache.druid.query.timeseries with type arguments of type AggregatorFactoryModifier and TypeMethodDescriptionstatic Object[]TimeseriesQueryQueryToolChest.getEmptyAggregations(List<AggregatorFactory> aggregatorSpecs) Returns a set of values that corresponds to an empty-set aggregation, which is used in situations where we want to return a single result representing "nothing was aggregated".TimeseriesQuery.withAggregatorSpecs(List<AggregatorFactory> aggregatorSpecs) Constructor parameters in org.apache.druid.query.timeseries with type arguments of type AggregatorFactoryModifierConstructorDescriptionTimeseriesBinaryFn(Granularity granularity, List<AggregatorFactory> aggregations) TimeseriesQuery(DataSource dataSource, QuerySegmentSpec querySegmentSpec, boolean descending, VirtualColumns virtualColumns, DimFilter dimFilter, Granularity granularity, List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs, int limit, Map<String, Object> context) -
Uses of AggregatorFactory in org.apache.druid.query.topn
Methods in org.apache.druid.query.topn that return types with arguments of type AggregatorFactoryMethods in org.apache.druid.query.topn with parameters of type AggregatorFactoryMethod parameters in org.apache.druid.query.topn with type arguments of type AggregatorFactoryModifier and TypeMethodDescriptionTopNQueryBuilder.aggregators(List<? extends AggregatorFactory> a) protected static String[]TopNQueryQueryToolChest.extractFactoryName(List<AggregatorFactory> aggregatorFactories) AlphaNumericTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs) DimensionTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs) InvertedTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs) LexicographicTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs) NumericTopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs) TopNMetricSpec.getComparator(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs) DimensionTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp, DimensionSpec dimSpec, int threshold, Comparator comparator, List<AggregatorFactory> aggFactories, List<PostAggregator> postAggs) InvertedTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp, DimensionSpec dimSpec, int threshold, Comparator comparator, List<AggregatorFactory> aggFactories, List<PostAggregator> postAggs) LexicographicTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp, DimensionSpec dimSpec, int threshold, Comparator comparator, List<AggregatorFactory> aggFactories, List<PostAggregator> postAggs) NumericTopNMetricSpec.getResultBuilder(org.joda.time.DateTime timestamp, DimensionSpec dimSpec, int threshold, Comparator comparator, List<AggregatorFactory> aggFactories, List<PostAggregator> postAggs) TopNMetricSpec.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) voidDimensionTopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs) voidInvertedTopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs) voidLexicographicTopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs) voidNumericTopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs) voidTopNMetricSpec.verifyPreconditions(List<AggregatorFactory> aggregatorSpecs, List<PostAggregator> postAggregatorSpecs) TopNQuery.withAggregatorSpecs(List<AggregatorFactory> aggregatorSpecs) Constructor parameters in org.apache.druid.query.topn with type arguments of type AggregatorFactoryModifierConstructorDescriptionTopNBinaryFn(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 org.apache.druid.segment
Methods in org.apache.druid.segment that return AggregatorFactoryModifier and TypeMethodDescriptionAggregateProjectionMetadata.Schema.getAggregators()Metadata.getAggregators()Methods in org.apache.druid.segment that return types with arguments of type AggregatorFactoryModifier and TypeMethodDescriptionSchemaPayload.getAggregatorFactories()CursorBuildSpec.CursorBuildSpecBuilder.getAggregators()CursorBuildSpec.getAggregators()AnyAggregatorFactorywhich will be used by a query engine for theCursorHolder, useful to assist in determining ifCursorHolder.canVectorize(), as well as specializing theCursororVectorCursorif any pre-aggregated data is available.default List<AggregatorFactory> CursorHolder.getAggregatorsForPreAggregated()Returns a set of replacementAggregatorFactoryif and only ifCursorHolder.isPreAggregated()is true.Methods in org.apache.druid.segment with parameters of type AggregatorFactoryModifier and TypeMethodDescriptionAggregateProjectionMetadata.SchemaBuilder.aggregators(AggregatorFactory... aggregators) IndexMerger.merge(List<IndexableAdapter> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, DimensionsSpec dimensionsSpec, IndexSpec indexSpec, int maxColumnsToMerge) Only used as a convenience method in tests.IndexMergerV9.merge(List<IndexableAdapter> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, DimensionsSpec dimensionsSpec, IndexSpec indexSpec, int maxColumnsToMerge) The indexes here must have the sameMetadata, otherwise an error would be thrown.static MetadataMetadata.merge(List<Metadata> toBeMerged, AggregatorFactory[] overrideMergedAggregators) default FileIndexMerger.mergeQueryableIndex(List<QueryableIndex> indexes, boolean rollup, AggregatorFactory[] metricAggs, File outDir, IndexSpec indexSpec, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, int maxColumnsToMerge) Merge a collection ofQueryableIndex.IndexMerger.mergeQueryableIndex(List<QueryableIndex> indexes, boolean rollup, AggregatorFactory[] metricAggs, DimensionsSpec dimensionsSpec, File outDir, IndexSpec indexSpec, IndexSpec indexSpecForIntermediatePersists, ProgressIndicator progress, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, int maxColumnsToMerge) Merge a collection ofQueryableIndex.IndexMergerV9.mergeQueryableIndex(List<QueryableIndex> indexes, boolean rollup, AggregatorFactory[] metricAggs, DimensionsSpec dimensionsSpec, File outDir, IndexSpec indexSpec, IndexSpec indexSpecForIntermediatePersists, ProgressIndicator progress, SegmentWriteOutMediumFactory segmentWriteOutMediumFactory, int maxColumnsToMerge) Method parameters in org.apache.druid.segment with type arguments of type AggregatorFactoryModifier and TypeMethodDescriptionCursorBuildSpec.CursorBuildSpecBuilder.setAggregators(List<AggregatorFactory> aggregators) Constructors in org.apache.druid.segment with parameters of type AggregatorFactoryModifierConstructorDescriptionMetadata(Map<String, Object> container, AggregatorFactory[] aggregators, TimestampSpec timestampSpec, Granularity queryGranularity, Boolean rollup, List<OrderBy> ordering, List<AggregateProjectionMetadata> projections) Schema(String name, String timeColumnName, DimFilter filter, VirtualColumns virtualColumns, List<String> groupingColumns, AggregatorFactory[] aggregators, List<OrderBy> ordering) Constructor parameters in org.apache.druid.segment with type arguments of type AggregatorFactoryModifierConstructorDescriptionSchemaPayload(RowSignature rowSignature, Map<String, AggregatorFactory> aggregatorFactories) -
Uses of AggregatorFactory in org.apache.druid.segment.column
Method parameters in org.apache.druid.segment.column with type arguments of type AggregatorFactoryModifier and TypeMethodDescriptionRowSignature.Builder.addAggregators(List<AggregatorFactory> aggregators, RowSignature.Finalization finalization) Adds aggregations to a signature. -
Uses of AggregatorFactory in org.apache.druid.segment.generator
Methods in org.apache.druid.segment.generator that return AggregatorFactoryMethods in org.apache.druid.segment.generator that return types with arguments of type AggregatorFactory -
Uses of AggregatorFactory in org.apache.druid.segment.incremental
Methods in org.apache.druid.segment.incremental that return AggregatorFactoryModifier and TypeMethodDescriptionIncrementalIndex.getMetricAggs()IncrementalIndexSchema.getMetrics()Methods in org.apache.druid.segment.incremental with parameters of type AggregatorFactoryModifier and TypeMethodDescriptionprotected abstract voidIncrementalIndex.initAggs(AggregatorFactory[] metrics, IncrementalIndex.InputRowHolder rowSupplier) protected voidOnheapIncrementalIndex.initAggs(AggregatorFactory[] metrics, IncrementalIndex.InputRowHolder inputRowHolder) protected ColumnSelectorFactoryIncrementalIndex.makeColumnSelectorFactory(AggregatorFactory agg, IncrementalIndex.InputRowHolder in) static ColumnSelectorFactoryIncrementalIndex.makeColumnSelectorFactory(VirtualColumns virtualColumns, IncrementalIndex.InputRowHolder inputRowHolder, AggregatorFactory agg) Column selector used at ingestion time for inputs to aggregators.AppendableIndexBuilder.setSimpleTestingIndexSchema(Boolean rollup, Boolean preserveExistingMetrics, AggregatorFactory... metrics) A helper method to set a simple index schema with controllable metrics and rollup, and default values for the other parameters.AppendableIndexBuilder.setSimpleTestingIndexSchema(AggregatorFactory... metrics) A helper method to set a simple index schema with only metrics and default values for the other parameters.IncrementalIndexSchema.Builder.withMetrics(AggregatorFactory... metrics) Constructors in org.apache.druid.segment.incremental with parameters of type AggregatorFactoryModifierConstructorDescriptionIncrementalIndexSchema(long minTimestamp, TimestampSpec timestampSpec, Granularity queryGranularity, VirtualColumns virtualColumns, DimensionsSpec dimensionsSpec, AggregatorFactory[] metrics, boolean rollup, List<AggregateProjectionSpec> projections) MetricDesc(int index, AggregatorFactory factory) -
Uses of AggregatorFactory in org.apache.druid.segment.projections
Methods in org.apache.druid.segment.projections with parameters of type AggregatorFactoryModifier and TypeMethodDescriptionProjectionMatchBuilder.addPreAggregatedAggregator(AggregatorFactory aggregator) Add a querysubstituteCombiningFactory(AggregatorFactory)which can combine the inputs of a selector created by a projectionAggregatorFactory -
Uses of AggregatorFactory in org.apache.druid.segment.serde
Methods in org.apache.druid.segment.serde with parameters of type AggregatorFactoryModifier and TypeMethodDescriptiondefault TComplexMetricExtractor.extractValue(InputRow inputRow, String metricName, AggregatorFactory agg) -
Uses of AggregatorFactory in org.apache.druid.timeline
Methods in org.apache.druid.timeline that return types with arguments of type AggregatorFactoryMethod parameters in org.apache.druid.timeline with type arguments of type AggregatorFactoryModifier and TypeMethodDescriptionstatic Function<Set<DataSegment>, Set<DataSegment>> CompactionState.addCompactionStateToSegments(PartitionsSpec partitionsSpec, DimensionsSpec dimensionsSpec, List<AggregatorFactory> metricsSpec, CompactionTransformSpec transformSpec, IndexSpec indexSpec, GranularitySpec granularitySpec, List<AggregateProjectionSpec> projections) Constructor parameters in org.apache.druid.timeline with type arguments of type AggregatorFactoryModifierConstructorDescriptionCompactionState(PartitionsSpec partitionsSpec, DimensionsSpec dimensionsSpec, List<AggregatorFactory> metricsSpec, CompactionTransformSpec transformSpec, IndexSpec indexSpec, GranularitySpec granularitySpec, List<AggregateProjectionSpec> projections)