Package org.apache.druid.query.groupby.epinephelinae
@EverythingIsNonnullByDefault
package org.apache.druid.query.groupby.epinephelinae
-
ClassDescriptionAbstractBufferHashGrouper<KeyType>A buffer grouper for array-based aggregation.BufferHashGrouper<KeyType>ByteBuffer-based implementation of the min-max heap developed by Atkinson, et al.CloseableGrouperIterator<KeyType,
T> ConcurrentGrouper<KeyType>Grouper based around a set of underlyingSpillingGrouperinstances.Utilities for parts of the groupBy engine that need to build dictionaries.CreatesColumnSelectorStrategys for grouping dimensions If the type is STRING, then it delegates the group by handling toKeyMappingMultiValueGroupByColumnSelectorStrategywhich is specialized forDimensionSelectors and multi-value dimensions.Class that knows how to merge a collection of groupByQueryRunnerobjects, calledqueryables, using a buffer provided bymergeBufferPooland a parallel executor provided byexec.Contains logic to process a groupBy query on a singleCursorFactoryin a non-vectorized manner.Class that knows how to merge aggregator data from two groupByResultRowobjects that have the same time and dimensions.Utility class that knows how to do higher-level groupBys: i.e.Grouper<KeyType>Groupers aggregate metrics from rows that they typically get from a ColumnSelectorFactory, under grouping keys that some outside driver is passing in.Possibly-stateful object responsible for serde and comparison of keys.Set of utility methods to faciliate implementation ofGrouper.KeySerde.bufferComparator()andGrouper.KeySerde.bufferComparatorWithAggregators(AggregatorFactory[], int[])An implementation ofVectorGrouperbacked by a growableMemoryOpenHashTable.Grouperspecialized for the primitive int typeLimitedBufferHashGrouper<KeyType>An area for limited temporary storage on disk.ParallelCombiner<KeyType>ParallelCombiner builds a combining tree which asynchronously aggregates input entries.ReusableEntry<KeyType>AGrouper.Entryimplementation that is reusable.This class contains shared code betweenGroupByMergingQueryRunnerandGroupByRowProcessor.SpillingGrouper<KeyType>Grouper based around a single underlyingBufferHashGrouper.StreamingMergeSortedGrouper<KeyType>A streaming grouper which can aggregate sorted inputs.Like aGrouper, but vectorized.