Uses of Interface
org.apache.druid.query.aggregation.BufferAggregator
Packages that use BufferAggregator
Package
Description
-
Uses of BufferAggregator in org.apache.druid.query.aggregation
Classes in org.apache.druid.query.aggregation that implement BufferAggregatorModifier and TypeClassDescriptionclassclassA BufferAggregator that delegates everything.classclassclassclassclassclassclassclassclassclassclassclassclassfinal classfinal classNull-aware numericBufferAggregator.classThis class can be used to wrap Double BufferAggregator that consume double type columns to handle Object type.classThis class can be used to wrap Float BufferAggregator that consume float type columns to handle Object type.classThis class can be used to wrap Long BufferAggregator that consume long type columns to handle Object type.classclassclassclassstatic classFields in org.apache.druid.query.aggregation declared as BufferAggregatorMethods in org.apache.druid.query.aggregation that return BufferAggregatorModifier and TypeMethodDescriptionprotected BufferAggregatorDoubleMaxAggregatorFactory.buildBufferAggregator(BaseDoubleColumnValueSelector selector) protected BufferAggregatorDoubleMinAggregatorFactory.buildBufferAggregator(BaseDoubleColumnValueSelector selector) protected BufferAggregatorDoubleSumAggregatorFactory.buildBufferAggregator(BaseDoubleColumnValueSelector selector) protected BufferAggregatorFloatMaxAggregatorFactory.buildBufferAggregator(BaseFloatColumnValueSelector selector) protected BufferAggregatorFloatMinAggregatorFactory.buildBufferAggregator(BaseFloatColumnValueSelector selector) protected BufferAggregatorFloatSumAggregatorFactory.buildBufferAggregator(BaseFloatColumnValueSelector selector) protected BufferAggregatorLongMaxAggregatorFactory.buildBufferAggregator(BaseLongColumnValueSelector selector) protected BufferAggregatorLongMinAggregatorFactory.buildBufferAggregator(BaseLongColumnValueSelector selector) protected BufferAggregatorLongSumAggregatorFactory.buildBufferAggregator(BaseLongColumnValueSelector selector) protected abstract BufferAggregatorSimpleDoubleAggregatorFactory.buildBufferAggregator(BaseDoubleColumnValueSelector selector) protected abstract BufferAggregatorSimpleFloatAggregatorFactory.buildBufferAggregator(BaseFloatColumnValueSelector selector) protected abstract BufferAggregatorSimpleLongAggregatorFactory.buildBufferAggregator(BaseLongColumnValueSelector selector) abstract BufferAggregatorAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) CountAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) ExpressionLambdaAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) FilteredAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory) GroupingAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) HistogramAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) JavaScriptAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory) final BufferAggregatorNullableNumericAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory) protected abstract BufferAggregatorNullableNumericAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnSelectorFactory, T selector) Creates anBufferAggregatorto aggregate values from several rows into a ByteBuffer.protected BufferAggregatorSimpleDoubleAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, ColumnValueSelector selector) protected BufferAggregatorSimpleFloatAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, ColumnValueSelector selector) protected BufferAggregatorSimpleLongAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory, ColumnValueSelector selector) SingleValueAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) SuppressedAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) SuppressedAggregatorFactory.SuppressedBufferAggregator.getDelegate()Constructors in org.apache.druid.query.aggregation with parameters of type BufferAggregatorModifierConstructorDescriptionFilteredBufferAggregator(ValueMatcher matcher, BufferAggregator delegate) NullableNumericBufferAggregator(BufferAggregator delegate, BaseNullableColumnValueSelector nullSelector) SuppressedBufferAggregator(BufferAggregator delegate) Constructor parameters in org.apache.druid.query.aggregation with type arguments of type BufferAggregatorModifierConstructorDescriptionObjectColumnDoubleBufferAggregatorWrapper(BaseObjectColumnValueSelector selector, Function<BaseDoubleColumnValueSelector, BufferAggregator> delegateBuilder, double nullValue) ObjectColumnFloatBufferAggregatorWrapper(BaseObjectColumnValueSelector selector, Function<BaseFloatColumnValueSelector, BufferAggregator> delegateBuilder, float nullValue) ObjectColumnLongBufferAggregatorWrapper(BaseObjectColumnValueSelector selector, Function<BaseLongColumnValueSelector, BufferAggregator> delegateBuilder, long nullValue) -
Uses of BufferAggregator in org.apache.druid.query.aggregation.any
Classes in org.apache.druid.query.aggregation.any that implement BufferAggregatorModifier and TypeClassDescriptionclassclassclassclassNumericAnyBufferAggregator<TSelector extends BaseNullableColumnValueSelector>Base type for buffer based 'any' aggregator for primitive numeric column selectorsclassMethods in org.apache.druid.query.aggregation.any that return BufferAggregatorModifier and TypeMethodDescriptionDoubleAnyAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) FloatAnyAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) LongAnyAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) StringAnyAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) -
Uses of BufferAggregator in org.apache.druid.query.aggregation.cardinality
Classes in org.apache.druid.query.aggregation.cardinality that implement BufferAggregatorMethods in org.apache.druid.query.aggregation.cardinality that return BufferAggregatorModifier and TypeMethodDescriptionCardinalityAggregatorFactory.factorizeBuffered(ColumnSelectorFactory columnFactory) -
Uses of BufferAggregator in org.apache.druid.query.aggregation.constant
Classes in org.apache.druid.query.aggregation.constant that implement BufferAggregator -
Uses of BufferAggregator in org.apache.druid.query.aggregation.firstlast.first
Classes in org.apache.druid.query.aggregation.firstlast.first that implement BufferAggregatorModifier and TypeClassDescriptionclassclassclassclassBase type for buffer based 'first' aggregator for primitive numeric column selectorsclassMethods in org.apache.druid.query.aggregation.firstlast.first that return BufferAggregatorModifier and TypeMethodDescriptionDoubleFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) FloatFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) LongFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) StringFirstAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) -
Uses of BufferAggregator in org.apache.druid.query.aggregation.firstlast.last
Classes in org.apache.druid.query.aggregation.firstlast.last that implement BufferAggregatorModifier and TypeClassDescriptionclassclassclassclassBase type for buffer based 'last' aggregator for primitive numeric column selectors This could probably share a base type withNumericFirstBufferAggregator...classMethods in org.apache.druid.query.aggregation.firstlast.last that return BufferAggregatorModifier and TypeMethodDescriptionDoubleLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) FloatLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) LongLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) StringLastAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) -
Uses of BufferAggregator in org.apache.druid.query.aggregation.hyperloglog
Classes in org.apache.druid.query.aggregation.hyperloglog that implement BufferAggregatorMethods in org.apache.druid.query.aggregation.hyperloglog that return BufferAggregatorModifier and TypeMethodDescriptionHyperUniquesAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) -
Uses of BufferAggregator in org.apache.druid.query.aggregation.mean
Classes in org.apache.druid.query.aggregation.mean that implement BufferAggregatorMethods in org.apache.druid.query.aggregation.mean that return BufferAggregatorModifier and TypeMethodDescriptionDoubleMeanAggregatorFactory.factorizeBuffered(ColumnSelectorFactory metricFactory) -
Uses of BufferAggregator in org.apache.druid.query.topn
Classes in org.apache.druid.query.topn with type parameters of type BufferAggregatorModifier and TypeInterfaceDescriptioninterfaceHistorical1AggPooledTopNScanner<DimensionSelectorType extends HistoricalDimensionSelector,MetricSelectorType, BufferAggregatorType extends BufferAggregator> Methods in org.apache.druid.query.topn that return BufferAggregatorModifier and TypeMethodDescriptionprotected static BufferAggregator[]BaseTopNAlgorithm.makeBufferAggregators(Cursor cursor, List<AggregatorFactory> aggregatorSpecs) protected BufferAggregator[]PooledTopNAlgorithm.makeDimValAggregateStore(PooledTopNAlgorithm.PooledTopNParams params) Methods in org.apache.druid.query.topn with parameters of type BufferAggregatorModifier and TypeMethodDescriptionprotected voidPooledTopNAlgorithm.resetAggregators(BufferAggregator[] bufferAggregators) longGeneric1AggPooledTopNScanner.scanAndAggregate(DimensionSelector dimensionSelector, BufferAggregator aggregator, int aggregatorSize, Cursor cursor, CursorGranularizer granularizer, int[] positions, ByteBuffer resultsBuffer) longGeneric1AggPooledTopNScannerPrototype.scanAndAggregate(DimensionSelector dimensionSelector, BufferAggregator aggregator, int aggregatorSize, Cursor cursor, CursorGranularizer granularizer, int[] positions, ByteBuffer resultsBuffer) Any changes to this method should be coordinated withTopNUtils,PooledTopNAlgorithm.computeSpecializedScanAndAggregateImplementations()and downstream methods.longGeneric2AggPooledTopNScanner.scanAndAggregate(DimensionSelector dimensionSelector, BufferAggregator aggregator1, int aggregator1Size, BufferAggregator aggregator2, int aggregator2Size, Cursor cursor, CursorGranularizer granularizer, int[] positions, ByteBuffer resultsBuffer) longGeneric2AggPooledTopNScannerPrototype.scanAndAggregate(DimensionSelector dimensionSelector, BufferAggregator aggregator1, int aggregator1Size, BufferAggregator aggregator2, int aggregator2Size, Cursor cursor, CursorGranularizer granularizer, int[] positions, ByteBuffer resultsBuffer) Any changes to this method should be coordinated withTopNUtils,PooledTopNAlgorithm.computeSpecializedScanAndAggregateImplementations()and downstream methods.protected longPooledTopNAlgorithm.scanAndAggregate(PooledTopNAlgorithm.PooledTopNParams params, int[] positions, BufferAggregator[] theAggregators) protected voidPooledTopNAlgorithm.updateResults(PooledTopNAlgorithm.PooledTopNParams params, int[] positions, BufferAggregator[] theAggregators, TopNResultBuilder resultBuilder)