Package | Description |
---|---|
io.druid.client | |
io.druid.curator.discovery | |
io.druid.server.coordination | |
io.druid.server.coordinator | |
io.druid.server.initialization | |
io.druid.server.listener.announcer |
Constructor and Description |
---|
BatchServerInventoryView(ZkPathsConfig zkPaths,
org.apache.curator.framework.CuratorFramework curator,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> defaultFilter)
Deprecated.
|
SingleServerInventoryView(ZkPathsConfig zkPaths,
org.apache.curator.framework.CuratorFramework curator,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.google.common.base.Predicate<Pair<DruidServerMetadata,DataSegment>> defaultFilter)
Deprecated.
|
Constructor and Description |
---|
CuratorDruidNodeAnnouncer(Announcer announcer,
ZkPathsConfig config,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
CuratorDruidNodeDiscoveryProvider(org.apache.curator.framework.CuratorFramework curatorFramework,
ZkPathsConfig config,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Constructor and Description |
---|
BatchDataSegmentAnnouncer(DruidServerMetadata server,
BatchDataSegmentAnnouncerConfig config,
ZkPathsConfig zkPaths,
Announcer announcer,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
CuratorDataSegmentServerAnnouncer(DruidServerMetadata server,
ZkPathsConfig config,
Announcer announcer,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
Deprecated.
|
ZkCoordinator(SegmentLoadDropHandler loadDropHandler,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
ZkPathsConfig zkPaths,
DruidServerMetadata me,
org.apache.curator.framework.CuratorFramework curator)
Deprecated.
|
Constructor and Description |
---|
DruidCoordinator(DruidCoordinatorConfig config,
ZkPathsConfig zkPaths,
JacksonConfigManager configManager,
MetadataSegmentManager metadataSegmentManager,
ServerInventoryView serverInventoryView,
MetadataRuleManager metadataRuleManager,
org.apache.curator.framework.CuratorFramework curator,
ServiceEmitter emitter,
ScheduledExecutorFactory scheduledExecutorFactory,
IndexingServiceClient indexingServiceClient,
LoadQueueTaskMaster taskMaster,
ServiceAnnouncer serviceAnnouncer,
DruidNode self,
Set<DruidCoordinatorHelper> indexingServiceHelpers,
BalancerStrategyFactory factory,
LookupCoordinatorManager lookupCoordinatorManager,
DruidLeaderSelector coordLeaderSelector) |
LoadQueueTaskMaster(org.apache.curator.framework.CuratorFramework curator,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
ScheduledExecutorService peonExec,
ExecutorService callbackExec,
DruidCoordinatorConfig config,
HttpClient httpClient,
ZkPathsConfig zkPaths) |
Modifier and Type | Method and Description |
---|---|
ZkPathsConfig |
IndexerZkConfig.getZkPathsConfig() |
Constructor and Description |
---|
IndexerZkConfig(ZkPathsConfig zkPathsConfig,
String base,
String announcementsPath,
String tasksPath,
String statusPath) |
Constructor and Description |
---|
ListeningAnnouncerConfig(ZkPathsConfig zkPathsConfig) |
Copyright © 2011–2018. All rights reserved.