Package | Description |
---|---|
io.druid.guice | |
io.druid.offheap | |
io.druid.query | |
io.druid.query.groupby | |
io.druid.query.topn | |
io.druid.segment.incremental |
Modifier and Type | Method and Description |
---|---|
StupidPool<ByteBuffer> |
DruidProcessingModule.getIntermediateResultsPool(DruidProcessingConfig config) |
Modifier and Type | Class and Description |
---|---|
class |
OffheapBufferPool |
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) |
Constructor and Description |
---|
AggregateTopNMetricFirstAlgorithm(Capabilities capabilities,
TopNQuery query,
StupidPool<ByteBuffer> bufferPool) |
PooledTopNAlgorithm(Capabilities capabilities,
TopNQuery query,
StupidPool<ByteBuffer> bufferPool) |
TopNQueryEngine(StupidPool<ByteBuffer> bufferPool) |
TopNQueryRunnerFactory(StupidPool<ByteBuffer> computationBufferPool,
TopNQueryQueryToolChest toolchest,
QueryWatcher queryWatcher) |
Constructor and Description |
---|
OffheapIncrementalIndex(IncrementalIndexSchema incrementalIndexSchema,
StupidPool<ByteBuffer> bufferPool,
boolean deserializeComplexMetrics,
int maxTotalBufferSize) |
OffheapIncrementalIndex(long minTimestamp,
QueryGranularity gran,
AggregatorFactory[] metrics,
StupidPool<ByteBuffer> bufferPool,
boolean deserializeComplexMetrics,
int maxTotalBufferSize) |
Copyright © 2011–2015. All rights reserved.