Uses of Interface
io.druid.collections.NonBlockingPool

Packages that use NonBlockingPool

Package	Description
io.druid.collections
io.druid.guice
io.druid.query
io.druid.query.groupby
io.druid.query.groupby.epinephelinae
io.druid.query.groupby.strategy
io.druid.query.topn
io.druid.segment.incremental

Uses of NonBlockingPool in io.druid.collections

Classes in io.druid.collections that implement NonBlockingPool

Modifier and Type	Class and Description
class	DummyNonBlockingPool<T> NonBlockingPool which is not able to allocate objects, DummyNonBlockingPool.take() throws UnsupportedOperationException.
class	StupidPool<T>

Methods in io.druid.collections that return NonBlockingPool

Modifier and Type	Method and Description
static <T> NonBlockingPool<T>	DummyNonBlockingPool.instance()

Uses of NonBlockingPool in io.druid.guice

Methods in io.druid.guice that return NonBlockingPool

Modifier and Type	Method and Description
NonBlockingPool<ByteBuffer>	RouterProcessingModule.getIntermediateResultsPool()
NonBlockingPool<ByteBuffer>	DruidProcessingModule.getIntermediateResultsPool(DruidProcessingConfig config)

Uses of NonBlockingPool in io.druid.query

Constructors in io.druid.query with parameters of type NonBlockingPool

Constructor and Description
GroupByMergedQueryRunner(ExecutorService exec, com.google.common.base.Supplier<GroupByQueryConfig> configSupplier, QueryWatcher queryWatcher, NonBlockingPool<ByteBuffer> bufferPool, Iterable<QueryRunner<T>> queryables)

Uses of NonBlockingPool in io.druid.query.groupby

Methods in io.druid.query.groupby with parameters of type NonBlockingPool

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)

Constructors in io.druid.query.groupby with parameters of type NonBlockingPool

Constructor and Description
GroupByQueryEngine(com.google.common.base.Supplier<GroupByQueryConfig> config, NonBlockingPool<ByteBuffer> intermediateResultsBufferPool)

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

Methods in io.druid.query.groupby.epinephelinae with parameters of type NonBlockingPool

Modifier and Type	Method and Description
static Sequence<Row>	GroupByQueryEngineV2.process(GroupByQuery query, StorageAdapter storageAdapter, NonBlockingPool<ByteBuffer> intermediateResultsBufferPool, GroupByQueryConfig config)

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

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 NonBlockingPool in io.druid.query.groupby.strategy

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

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)

Uses of NonBlockingPool in io.druid.query.topn

Constructors in io.druid.query.topn with parameters of type NonBlockingPool

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)

Uses of NonBlockingPool in io.druid.segment.incremental

Methods in io.druid.segment.incremental with parameters of type NonBlockingPool

Modifier and Type	Method and Description
IncrementalIndex	IncrementalIndex.Builder.buildOffheap(NonBlockingPool<ByteBuffer> bufferPool)