Modifier and Type | Class and Description |
---|---|
class |
DummyNonBlockingPool<T>
NonBlockingPool which is not able to allocate objects,
DummyNonBlockingPool.take() throws UnsupportedOperationException . |
class |
StupidPool<T> |
Modifier and Type | Method and Description |
---|---|
static <T> NonBlockingPool<T> |
DummyNonBlockingPool.instance() |
Modifier and Type | Method and Description |
---|---|
NonBlockingPool<ByteBuffer> |
RouterProcessingModule.getIntermediateResultsPool() |
NonBlockingPool<ByteBuffer> |
DruidProcessingModule.getIntermediateResultsPool(DruidProcessingConfig config) |
Constructor and Description |
---|
GroupByMergedQueryRunner(ExecutorService exec,
com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
QueryWatcher queryWatcher,
NonBlockingPool<ByteBuffer> bufferPool,
Iterable<QueryRunner<T>> queryables) |
Modifier and Type | Method and Description |
---|---|
static <T> Pair<IncrementalIndex,Accumulator<IncrementalIndex,T>> |
GroupByQueryHelper.createIndexAccumulatorPair(GroupByQuery query,
GroupByQueryConfig config,
NonBlockingPool<ByteBuffer> bufferPool,
boolean combine) |
static IncrementalIndex |
GroupByQueryHelper.makeIncrementalIndex(GroupByQuery query,
GroupByQueryConfig config,
NonBlockingPool<ByteBuffer> bufferPool,
Sequence<Row> rows,
boolean combine) |
Constructor and Description |
---|
GroupByQueryEngine(com.google.common.base.Supplier<GroupByQueryConfig> config,
NonBlockingPool<ByteBuffer> intermediateResultsBufferPool) |
Modifier and Type | Method and Description |
---|---|
static Sequence<Row> |
GroupByQueryEngineV2.process(GroupByQuery query,
StorageAdapter storageAdapter,
NonBlockingPool<ByteBuffer> intermediateResultsBufferPool,
GroupByQueryConfig config) |
Constructor and Description |
---|
GroupByMergingQueryRunnerV2(GroupByQueryConfig config,
ExecutorService exec,
QueryWatcher queryWatcher,
Iterable<QueryRunner<Row>> queryables,
int concurrencyHint,
NonBlockingPool<ByteBuffer> processingBufferPool,
BlockingPool<ByteBuffer> mergeBufferPool,
int mergeBufferSize,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
String processingTmpDir) |
Constructor and Description |
---|
GroupByStrategyV1(com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
GroupByQueryEngine engine,
QueryWatcher queryWatcher,
NonBlockingPool<ByteBuffer> bufferPool) |
GroupByStrategyV2(DruidProcessingConfig processingConfig,
com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
NonBlockingPool<ByteBuffer> bufferPool,
BlockingPool<ByteBuffer> mergeBufferPool,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
QueryWatcher queryWatcher) |
Constructor and Description |
---|
AggregateTopNMetricFirstAlgorithm(Capabilities capabilities,
TopNQuery query,
NonBlockingPool<ByteBuffer> bufferPool) |
PooledTopNAlgorithm(Capabilities capabilities,
TopNQuery query,
NonBlockingPool<ByteBuffer> bufferPool) |
TopNQueryEngine(NonBlockingPool<ByteBuffer> bufferPool) |
TopNQueryRunnerFactory(NonBlockingPool<ByteBuffer> computationBufferPool,
TopNQueryQueryToolChest toolchest,
QueryWatcher queryWatcher) |
Modifier and Type | Method and Description |
---|---|
IncrementalIndex |
IncrementalIndex.Builder.buildOffheap(NonBlockingPool<ByteBuffer> bufferPool) |
Copyright © 2011–2018. All rights reserved.