| Constructor and Description |
|---|
CoordinatorClient(com.metamx.http.client.HttpClient client,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
ServerDiscoverySelector selector) |
| Constructor and Description |
|---|
IndexingServiceClient(com.metamx.http.client.HttpClient client,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
ServerDiscoverySelector selector) |
| Modifier and Type | Method and Description |
|---|---|
StupidPool<ByteBuffer> |
DruidProcessingModule.getIntermediateResultsPool(DruidProcessingConfig config) |
| Constructor and Description |
|---|
RemoteTaskActionClientFactory(com.metamx.http.client.HttpClient httpClient,
ServerDiscoverySelector selector,
RetryPolicyFactory retryPolicyFactory,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
| Constructor and Description |
|---|
KafkaIndexTaskClientFactory(com.metamx.http.client.HttpClient httpClient,
com.fasterxml.jackson.databind.ObjectMapper mapper) |
| Constructor and Description |
|---|
RemoteTaskRunnerFactory(org.apache.curator.framework.CuratorFramework curator,
RemoteTaskRunnerConfig remoteTaskRunnerConfig,
IndexerZkConfig zkPaths,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.metamx.http.client.HttpClient httpClient,
com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
ScheduledExecutorFactory factory,
ResourceManagementSchedulerConfig resourceManagementSchedulerConfig,
ResourceManagementStrategy resourceManagementStrategy) |
| Constructor and Description |
|---|
GroupByQueryEngine(com.google.common.base.Supplier<GroupByQueryConfig> config,
StupidPool<ByteBuffer> intermediateResultsBufferPool) |
| Constructor and Description |
|---|
GroupByStrategyV1(com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
GroupByQueryEngine engine,
QueryWatcher queryWatcher,
StupidPool<ByteBuffer> bufferPool) |
GroupByStrategyV2(DruidProcessingConfig processingConfig,
com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
StupidPool<ByteBuffer> bufferPool,
BlockingPool<ByteBuffer> mergeBufferPool,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
QueryWatcher queryWatcher) |
| Constructor and Description |
|---|
TopNQueryRunnerFactory(StupidPool<ByteBuffer> computationBufferPool,
TopNQueryQueryToolChest toolchest,
QueryWatcher queryWatcher) |
| Constructor and Description |
|---|
LookupCoordinatorManager(com.metamx.http.client.HttpClient httpClient,
ListenerDiscoverer listenerDiscoverer,
com.fasterxml.jackson.databind.ObjectMapper smileMapper,
JacksonConfigManager configManager,
LookupCoordinatorManagerConfig lookupCoordinatorManagerConfig) |
| Constructor and Description |
|---|
CoordinatorRuleManager(com.metamx.http.client.HttpClient httpClient,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.google.common.base.Supplier<TieredBrokerConfig> config,
ServerDiscoverySelector selector) |
Copyright © 2011–2017. All rights reserved.