Package | Description |
---|---|
io.druid.query.groupby.epinephelinae |
Modifier and Type | Method and Description |
---|---|
default AggregateResult |
IntGrouper.aggregate(int key) |
default AggregateResult |
IntGrouper.aggregate(Integer key)
Deprecated.
Please use
IntGrouper.aggregate(int) instead. |
default AggregateResult |
IntGrouper.aggregate(Integer key,
int keyHash)
Deprecated.
Please use
IntGrouper.aggregateKeyHash(int) instead. |
AggregateResult |
StreamingMergeSortedGrouper.aggregate(KeyType key) |
default AggregateResult |
Grouper.aggregate(KeyType key)
Aggregate the current row with the provided key.
|
AggregateResult |
StreamingMergeSortedGrouper.aggregate(KeyType key,
int notUsed) |
AggregateResult |
SpillingGrouper.aggregate(KeyType key,
int keyHash) |
AggregateResult |
Grouper.aggregate(KeyType key,
int keyHash)
Aggregate the current row with the provided key.
|
AggregateResult |
ConcurrentGrouper.aggregate(KeyType key,
int keyHash) |
AggregateResult |
AbstractBufferHashGrouper.aggregate(KeyType key,
int keyHash) |
AggregateResult |
IntGrouper.aggregateKeyHash(int keyHash) |
AggregateResult |
BufferArrayGrouper.aggregateKeyHash(int dimIndex) |
static AggregateResult |
AggregateResult.failure(String reason) |
static AggregateResult |
AggregateResult.ok() |
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.
|
Copyright © 2011–2018. All rights reserved.