| Package | Description |
|---|---|
| io.druid.client.indexing | |
| io.druid.guice | |
| io.druid.indexing.common.actions | |
| io.druid.indexing.overlord |
| Constructor and Description |
|---|
IndexingServiceClient(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
DruidLeaderClient druidLeaderClient) |
| Modifier and Type | Method and Description |
|---|---|
DruidLeaderClient |
IndexingServiceDiscoveryModule.getLeaderHttpClient(HttpClient httpClient,
DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
ServerDiscoverySelector serverDiscoverySelector) |
ServerDiscoverySelector |
IndexingServiceDiscoveryModule.getServiceProvider(IndexingServiceSelectorConfig config,
ServerDiscoveryFactory serverDiscoveryFactory) |
| Modifier and Type | Method and Description |
|---|---|
DruidLeaderClient |
IndexingServiceDiscoveryModule.getLeaderHttpClient(HttpClient httpClient,
DruidNodeDiscoveryProvider druidNodeDiscoveryProvider,
ServerDiscoverySelector serverDiscoverySelector) |
| Constructor and Description |
|---|
RemoteTaskActionClientFactory(DruidLeaderClient leaderHttpClient,
RetryPolicyFactory retryPolicyFactory,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
| Constructor and Description |
|---|
TaskMaster(TaskQueueConfig taskQueueConfig,
TaskLockbox taskLockbox,
TaskStorage taskStorage,
TaskActionClientFactory taskActionClientFactory,
DruidNode selfNode,
TaskRunnerFactory runnerFactory,
ServiceAnnouncer serviceAnnouncer,
CoordinatorOverlordServiceConfig coordinatorOverlordServiceConfig,
ServiceEmitter emitter,
SupervisorManager supervisorManager,
OverlordHelperManager overlordHelperManager,
DruidLeaderSelector overlordLeaderSelector) |
Copyright © 2011–2018. All rights reserved.