| 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.