Package | Description |
---|---|
io.druid.guice | |
io.druid.query.groupby | |
io.druid.query.groupby.strategy | |
io.druid.query.topn | |
io.druid.server.coordinator |
Modifier and Type | Method and Description |
---|---|
NonBlockingPool<ByteBuffer> |
RouterProcessingModule.getIntermediateResultsPool() |
NonBlockingPool<ByteBuffer> |
DruidProcessingModule.getIntermediateResultsPool(DruidProcessingConfig config) |
Constructor and Description |
---|
GroupByQueryEngine(com.google.common.base.Supplier<GroupByQueryConfig> config,
NonBlockingPool<ByteBuffer> intermediateResultsBufferPool) |
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 |
---|
TopNQueryRunnerFactory(NonBlockingPool<ByteBuffer> computationBufferPool,
TopNQueryQueryToolChest toolchest,
QueryWatcher queryWatcher) |
Constructor and Description |
---|
LoadQueueTaskMaster(org.apache.curator.framework.CuratorFramework curator,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
ScheduledExecutorService peonExec,
ExecutorService callbackExec,
DruidCoordinatorConfig config,
HttpClient httpClient,
ZkPathsConfig zkPaths) |
Copyright © 2011–2018. All rights reserved.