Package | Description |
---|---|
io.druid.guice | |
io.druid.query | |
io.druid.query.groupby.strategy |
Modifier and Type | Method and Description |
---|---|
StupidPool<ByteBuffer> |
DruidProcessingModule.getIntermediateResultsPool(DruidProcessingConfig config) |
BlockingPool<ByteBuffer> |
DruidProcessingModule.getMergeBufferPool(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,
StupidPool<ByteBuffer> bufferPool,
BlockingPool<ByteBuffer> mergeBufferPool,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
QueryWatcher queryWatcher) |
Copyright © 2011–2017. All rights reserved.