| Package | Description |
|---|---|
| io.druid.client | |
| io.druid.guice | |
| io.druid.indexing.kafka | |
| io.druid.indexing.overlord | |
| io.druid.server.lookup.cache |
| Constructor and Description |
|---|
HttpServerInventoryView(com.fasterxml.jackson.databind.ObjectMapper smileMapper,
HttpClient httpClient,
DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> defaultFilter,
HttpServerInventoryViewConfig config) |
| Modifier and Type | Method and Description |
|---|---|
DruidLeaderClient |
IndexingServiceDiscoveryModule.getLeaderHttpClient(HttpClient httpClient,
DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
ServerDiscoverySelector serverDiscoverySelector) |
DruidLeaderClient |
CoordinatorDiscoveryModule.getLeaderHttpClient(HttpClient httpClient,
DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
ServerDiscoverySelector serverDiscoverySelector) |
| Constructor and Description |
|---|
KafkaIndexTaskClientFactory(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,
HttpClient httpClient,
com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef,
ProvisioningSchedulerConfig provisioningSchedulerConfig,
ProvisioningStrategy provisioningStrategy) |
| Constructor and Description |
|---|
LookupCoordinatorManager(HttpClient httpClient,
DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
com.fasterxml.jackson.databind.ObjectMapper smileMapper,
JacksonConfigManager configManager,
LookupCoordinatorManagerConfig lookupCoordinatorManagerConfig) |
Copyright © 2011–2018. All rights reserved.