| 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.