Package | Description |
---|---|
io.druid.query | |
io.druid.query.groupby | |
io.druid.query.groupby.epinephelinae | |
io.druid.query.groupby.strategy |
Constructor and Description |
---|
GroupByMergedQueryRunner(ExecutorService exec,
com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
QueryWatcher queryWatcher,
StupidPool<ByteBuffer> bufferPool,
Iterable<QueryRunner<T>> queryables) |
Modifier and Type | Method and Description |
---|---|
GroupByQueryConfig |
GroupByQueryConfig.withOverrides(GroupByQuery query) |
Modifier and Type | Method and Description |
---|---|
static <T> Pair<IncrementalIndex,Accumulator<IncrementalIndex,T>> |
GroupByQueryHelper.createIndexAccumulatorPair(GroupByQuery query,
GroupByQueryConfig config,
StupidPool<ByteBuffer> bufferPool,
boolean combine) |
static IncrementalIndex |
GroupByQueryHelper.makeIncrementalIndex(GroupByQuery query,
GroupByQueryConfig config,
StupidPool<ByteBuffer> bufferPool,
Sequence<Row> rows,
boolean combine) |
Constructor and Description |
---|
GroupByQueryEngine(com.google.common.base.Supplier<GroupByQueryConfig> config,
StupidPool<ByteBuffer> intermediateResultsBufferPool) |
Modifier and Type | Method and Description |
---|---|
static Pair<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Accumulator<Grouper<io.druid.query.groupby.epinephelinae.RowBasedGrouperHelper.RowBasedKey>,Row>> |
RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query,
boolean isInputRaw,
Map<String,ValueType> rawInputRowSignature,
GroupByQueryConfig config,
com.google.common.base.Supplier<ByteBuffer> bufferSupplier,
int concurrencyHint,
LimitedTemporaryStorage temporaryStorage,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
AggregatorFactory[] aggregatorFactories)
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 Sequence<Row> |
GroupByQueryEngineV2.process(GroupByQuery query,
StorageAdapter storageAdapter,
StupidPool<ByteBuffer> intermediateResultsBufferPool,
GroupByQueryConfig config) |
static Sequence<Row> |
GroupByRowProcessor.process(Query queryParam,
Sequence<Row> rows,
Map<String,ValueType> rowSignature,
GroupByQueryConfig config,
GroupByQueryResource resource,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
String processingTmpDir) |
Constructor and Description |
---|
GroupByMergingQueryRunnerV2(GroupByQueryConfig config,
ExecutorService exec,
QueryWatcher queryWatcher,
Iterable<QueryRunner<Row>> queryables,
int concurrencyHint,
BlockingPool<ByteBuffer> mergeBufferPool,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
String processingTmpDir) |
Constructor and Description |
---|
GroupByStrategySelector(com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
GroupByStrategyV1 strategyV1,
GroupByStrategyV2 strategyV2) |
GroupByStrategyV1(com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
GroupByQueryEngine engine,
QueryWatcher queryWatcher,
StupidPool<ByteBuffer> bufferPool) |
GroupByStrategyV2(DruidProcessingConfig processingConfig,
com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
StupidPool<ByteBuffer> bufferPool,
BlockingPool<ByteBuffer> mergeBufferPool,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
QueryWatcher queryWatcher) |
Copyright © 2011–2017. All rights reserved.