Uses of Interface
org.apache.druid.query.groupby.epinephelinae.Grouper

Packages that use Grouper

Package	Description
org.apache.druid.query.groupby.epinephelinae

Uses of Grouper in org.apache.druid.query.groupby.epinephelinae

Subinterfaces of Grouper in org.apache.druid.query.groupby.epinephelinae

Modifier and Type	Interface and Description
interface	IntGrouper Grouper specialized for the primitive int type

Classes in org.apache.druid.query.groupby.epinephelinae that implement Grouper

Modifier and Type	Class and Description
class	AbstractBufferHashGrouper<KeyType>
class	BufferArrayGrouper A buffer grouper for array-based aggregation.
class	BufferHashGrouper<KeyType>
class	ConcurrentGrouper<KeyType> Grouper based around a set of underlying SpillingGrouper instances.
class	LimitedBufferHashGrouper<KeyType>
class	SpillingGrouper<KeyType> Grouper based around a single underlying BufferHashGrouper.
class	StreamingMergeSortedGrouper<KeyType> A streaming grouper which can aggregate sorted inputs.

Methods in org.apache.druid.query.groupby.epinephelinae that return Grouper

Modifier and Type	Method and Description
static Grouper	GroupByRowProcessor.createGrouper(Query queryParam, Sequence<Row> rows, Map<String,ValueType> rowSignature, GroupByQueryConfig config, GroupByQueryResource resource, com.fasterxml.jackson.databind.ObjectMapper spillMapper, String processingTmpDir, int mergeBufferSize, List<Closeable> closeOnExit, boolean wasQueryPushedDown)

Methods in org.apache.druid.query.groupby.epinephelinae that return types with arguments of type Grouper

Modifier and Type	Method and Description
static Pair<Grouper<org.apache.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>>	RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query, boolean isInputRaw, Map<String,ValueType> rawInputRowSignature, GroupByQueryConfig config, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, AggregatorFactory[] aggregatorFactories, int mergeBufferSize) Create a single-threaded grouper and accumulator.
static Pair<Grouper<org.apache.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>>	RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query, boolean isInputRaw, Map<String,ValueType> rawInputRowSignature, GroupByQueryConfig config, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, ReferenceCountingResourceHolder<ByteBuffer> combineBufferHolder, int concurrencyHint, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, AggregatorFactory[] aggregatorFactories, com.google.common.util.concurrent.ListeningExecutorService grouperSorter, int priority, boolean hasQueryTimeout, long queryTimeoutAt, int mergeBufferSize) 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.

Methods in org.apache.druid.query.groupby.epinephelinae with parameters of type Grouper

Modifier and Type	Method and Description
static CloseableGrouperIterator<org.apache.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey,Row>	RowBasedGrouperHelper.makeGrouperIterator(Grouper<org.apache.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey> grouper, GroupByQuery query, Closeable closeable)
static CloseableGrouperIterator<org.apache.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey,Row>	RowBasedGrouperHelper.makeGrouperIterator(Grouper<org.apache.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey> grouper, GroupByQuery query, List<String> dimsToInclude, Closeable closeable)

Method parameters in org.apache.druid.query.groupby.epinephelinae with type arguments of type Grouper

Modifier and Type	Method and Description
static Sequence<Row>	GroupByRowProcessor.getRowsFromGrouper(GroupByQuery query, List<String> subtotalSpec, com.google.common.base.Supplier<Grouper> grouper)

Constructors in org.apache.druid.query.groupby.epinephelinae with parameters of type Grouper

Constructor and Description
CloseableGrouperIterator(Grouper<KeyType> grouper, boolean sorted, Function<Grouper.Entry<KeyType>,T> transformer, Closeable closeable)