Package | Description |
---|---|
io.druid.query.groupby.epinephelinae |
Modifier and Type | Interface and Description |
---|---|
interface |
IntGrouper
Grouper specialized for the primitive int type |
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.
|
Modifier and Type | Method and Description |
---|---|
static Pair<Grouper<io.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<io.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,
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.
|
Modifier and Type | Method and Description |
---|---|
static CloseableGrouperIterator<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey,Row> |
RowBasedGrouperHelper.makeGrouperIterator(Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey> grouper,
GroupByQuery query,
Closeable closeable) |
Constructor and Description |
---|
CloseableGrouperIterator(Grouper<KeyType> grouper,
boolean sorted,
Function<Grouper.Entry<KeyType>,T> transformer,
Closeable closeable) |
Copyright © 2011–2018. All rights reserved.