Uses of Interface
io.druid.collections.BlockingPool

Packages that use BlockingPool

Package	Description
io.druid.collections
io.druid.guice
io.druid.query.groupby.epinephelinae
io.druid.query.groupby.strategy

Uses of BlockingPool in io.druid.collections

Classes in io.druid.collections that implement BlockingPool

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.

Methods in io.druid.collections that return BlockingPool

Modifier and Type	Method and Description
static <T> BlockingPool<T>	DummyBlockingPool.instance()

Uses of BlockingPool in io.druid.guice

Methods in io.druid.guice that return BlockingPool

Modifier and Type	Method and Description
BlockingPool<ByteBuffer>	RouterProcessingModule.getMergeBufferPool(DruidProcessingConfig config)
BlockingPool<ByteBuffer>	DruidProcessingModule.getMergeBufferPool(DruidProcessingConfig config)

Uses of BlockingPool in io.druid.query.groupby.epinephelinae

Constructors in io.druid.query.groupby.epinephelinae with parameters of type BlockingPool

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)

Uses of BlockingPool in io.druid.query.groupby.strategy

Constructors in io.druid.query.groupby.strategy with parameters of type BlockingPool

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)