Package | Description |
---|---|
io.druid.query | |
io.druid.query.groupby |
Constructor and Description |
---|
GroupByParallelQueryRunner(ExecutorService exec,
com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
QueryWatcher queryWatcher,
StupidPool<ByteBuffer> bufferPool,
Iterable<QueryRunner<T>> queryables) |
Modifier and Type | Method and Description |
---|---|
static <T> com.metamx.common.Pair<IncrementalIndex,com.metamx.common.guava.Accumulator<IncrementalIndex,T>> |
GroupByQueryHelper.createIndexAccumulatorPair(GroupByQuery query,
GroupByQueryConfig config,
StupidPool<ByteBuffer> bufferPool) |
Constructor and Description |
---|
GroupByQueryEngine(com.google.common.base.Supplier<GroupByQueryConfig> config,
StupidPool<ByteBuffer> intermediateResultsBufferPool) |
GroupByQueryQueryToolChest(com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
GroupByQueryEngine engine,
StupidPool<ByteBuffer> bufferPool,
IntervalChunkingQueryRunnerDecorator intervalChunkingQueryRunnerDecorator) |
GroupByQueryRunnerFactory(GroupByQueryEngine engine,
QueryWatcher queryWatcher,
com.google.common.base.Supplier<GroupByQueryConfig> config,
GroupByQueryQueryToolChest toolChest,
StupidPool<ByteBuffer> computationBufferPool) |
Copyright © 2011–2015. All rights reserved.