public class RowBasedGrouperHelper extends Object
Constructor and Description |
---|
RowBasedGrouperHelper() |
Modifier and Type | Method and Description |
---|---|
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> |
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<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> |
createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
com.google.common.base.Supplier<ResourceHolder<ByteBuffer>> combineBufferSupplier,
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.
|
static CloseableGrouperIterator<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey,Row> |
makeGrouperIterator(Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey> grouper,
GroupByQuery query,
Closeable closeable) |
public static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> 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)
public static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,Row>> createGrouperAccumulatorPair(GroupByQuery query, boolean isInputRaw, Map<String,ValueType> rawInputRowSignature, GroupByQueryConfig config, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, com.google.common.base.Supplier<ResourceHolder<ByteBuffer>> combineBufferSupplier, int concurrencyHint, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, AggregatorFactory[] aggregatorFactories, @Nullable com.google.common.util.concurrent.ListeningExecutorService grouperSorter, int priority, boolean hasQueryTimeout, long queryTimeoutAt, int mergeBufferSize)
public static CloseableGrouperIterator<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey,Row> makeGrouperIterator(Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey> grouper, GroupByQuery query, Closeable closeable)
Copyright © 2011–2018. All rights reserved.