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.