| Package | Description | 
|---|---|
| io.druid.guice | |
| io.druid.query | |
| io.druid.query.groupby.strategy | 
| Modifier and Type | Method and Description | 
|---|---|
NonBlockingPool<ByteBuffer> | 
DruidProcessingModule.getIntermediateResultsPool(DruidProcessingConfig config)  | 
BlockingPool<ByteBuffer> | 
RouterProcessingModule.getMergeBufferPool(DruidProcessingConfig config)  | 
BlockingPool<ByteBuffer> | 
DruidProcessingModule.getMergeBufferPool(DruidProcessingConfig config)  | 
ExecutorService | 
RouterProcessingModule.getProcessingExecutorService(DruidProcessingConfig config)  | 
ExecutorService | 
DruidProcessingModule.getProcessingExecutorService(DruidProcessingConfig config,
                            ExecutorServiceMonitor executorServiceMonitor,
                            Lifecycle lifecycle)  | 
| Modifier and Type | Method and Description | 
|---|---|
static PrioritizedExecutorService | 
PrioritizedExecutorService.create(Lifecycle lifecycle,
      DruidProcessingConfig config)  | 
| Constructor and Description | 
|---|
PrioritizedExecutorService(ThreadPoolExecutor threadPoolExecutor,
                          boolean allowRegularTasks,
                          int defaultPriority,
                          DruidProcessingConfig config)  | 
PrioritizedExecutorService(ThreadPoolExecutor threadPoolExecutor,
                          DruidProcessingConfig config)  | 
| 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.