Package | Description |
---|---|
io.druid.collections | |
io.druid.guice | |
io.druid.query.groupby.epinephelinae | |
io.druid.query.groupby.strategy |
Modifier and Type | Class and Description |
---|---|
class |
DefaultBlockingPool<T>
Pool that pre-generates objects up to a limit, then permits possibly-blocking "take" operations.
|
class |
DummyBlockingPool<T>
BlockingPool with 0 maxSize, all take*() methods immediately throw
UnsupportedOperationException . |
Modifier and Type | Method and Description |
---|---|
static <T> BlockingPool<T> |
DummyBlockingPool.instance() |
Modifier and Type | Method and Description |
---|---|
BlockingPool<ByteBuffer> |
RouterProcessingModule.getMergeBufferPool(DruidProcessingConfig config) |
BlockingPool<ByteBuffer> |
DruidProcessingModule.getMergeBufferPool(DruidProcessingConfig 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 |
---|
GroupByStrategyV2(DruidProcessingConfig processingConfig,
com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
NonBlockingPool<ByteBuffer> bufferPool,
BlockingPool<ByteBuffer> mergeBufferPool,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
QueryWatcher queryWatcher) |
Copyright © 2011–2018. All rights reserved.