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.