| Constructor and Description | 
|---|
DruidServer(DruidNode node,
           DruidServerConfig config,
           ServerType type)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
ServiceAnnouncer.announce(DruidNode node)
Deprecated.  
  | 
void | 
NoopServiceAnnouncer.announce(DruidNode node)
Deprecated.  
  | 
void | 
CuratorServiceAnnouncer.announce(DruidNode service)
Deprecated.  
  | 
void | 
ServiceAnnouncer.unannounce(DruidNode node)
Deprecated.  
  | 
void | 
NoopServiceAnnouncer.unannounce(DruidNode node)
Deprecated.  
  | 
void | 
CuratorServiceAnnouncer.unannounce(DruidNode service)
Deprecated.  
  | 
| Modifier and Type | Method and Description | 
|---|---|
CuratorServiceAnnouncer | 
DiscoveryModule.getServiceAnnouncer(CuratorServiceAnnouncer announcer,
                   com.google.inject.Injector injector,
                   Set<KeyHolder<DruidNode>> nodesToAnnounce,
                   Lifecycle lifecycle)  | 
static void | 
DiscoveryModule.registerKey(com.google.inject.Binder binder,
           com.google.inject.Key<DruidNode> key)
Requests that the keyed DruidNode instance be injected and published as part of the lifecycle. 
 | 
| Constructor and Description | 
|---|
CuratorDruidLeaderSelector(org.apache.curator.framework.CuratorFramework curator,
                          DruidNode self,
                          String latchPath)  | 
| Modifier and Type | Method and Description | 
|---|---|
DruidNode | 
DiscoveryDruidNode.getDruidNode()  | 
| Constructor and Description | 
|---|
DiscoveryDruidNode(DruidNode druidNode,
                  String nodeType,
                  Map<String,DruidService> services)  | 
| Modifier and Type | Method and Description | 
|---|---|
static com.google.inject.multibindings.Multibinder<KeyHolder<DruidNode>> | 
DruidBinders.discoveryAnnouncementBinder(com.google.inject.Binder binder)  | 
| Modifier and Type | Method and Description | 
|---|---|
DruidServerMetadata | 
StorageNodeModule.getMetadata(DruidNode node,
           NodeTypeConfig nodeType,
           DruidServerConfig config)  | 
| Modifier and Type | Method and Description | 
|---|---|
DruidNode | 
TaskToolbox.getDruidNode()  | 
| Constructor and Description | 
|---|
TaskToolbox(TaskConfig config,
           TaskActionClient taskActionClient,
           ServiceEmitter emitter,
           DataSegmentPusher segmentPusher,
           DataSegmentKiller dataSegmentKiller,
           DataSegmentMover dataSegmentMover,
           DataSegmentArchiver dataSegmentArchiver,
           DataSegmentAnnouncer segmentAnnouncer,
           DataSegmentServerAnnouncer serverAnnouncer,
           SegmentHandoffNotifierFactory handoffNotifierFactory,
           com.google.inject.Provider<QueryRunnerFactoryConglomerate> queryRunnerFactoryConglomerateProvider,
           ExecutorService queryExecutorService,
           MonitorScheduler monitorScheduler,
           SegmentLoader segmentLoader,
           com.fasterxml.jackson.databind.ObjectMapper objectMapper,
           File taskWorkDir,
           IndexIO indexIO,
           Cache cache,
           CacheConfig cacheConfig,
           IndexMergerV9 indexMergerV9,
           DruidNodeAnnouncer druidNodeAnnouncer,
           DruidNode druidNode,
           LookupNodeService lookupNodeService,
           DataNodeService dataNodeService)  | 
TaskToolboxFactory(TaskConfig config,
                  TaskActionClientFactory taskActionClientFactory,
                  ServiceEmitter emitter,
                  DataSegmentPusher segmentPusher,
                  DataSegmentKiller dataSegmentKiller,
                  DataSegmentMover dataSegmentMover,
                  DataSegmentArchiver dataSegmentArchiver,
                  DataSegmentAnnouncer segmentAnnouncer,
                  DataSegmentServerAnnouncer serverAnnouncer,
                  SegmentHandoffNotifierFactory handoffNotifierFactory,
                  com.google.inject.Provider<QueryRunnerFactoryConglomerate> queryRunnerFactoryConglomerateProvider,
                  ExecutorService queryExecutorService,
                  MonitorScheduler monitorScheduler,
                  SegmentLoaderFactory segmentLoaderFactory,
                  com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                  IndexIO indexIO,
                  Cache cache,
                  CacheConfig cacheConfig,
                  IndexMergerV9 indexMergerV9,
                  DruidNodeAnnouncer druidNodeAnnouncer,
                  DruidNode druidNode,
                  LookupNodeService lookupNodeService,
                  DataNodeService dataNodeService)  | 
| Constructor and Description | 
|---|
ForkingTaskRunner(ForkingTaskRunnerConfig config,
                 TaskConfig taskConfig,
                 WorkerConfig workerConfig,
                 Properties props,
                 TaskLogPusher taskLogPusher,
                 com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                 DruidNode node)  | 
ForkingTaskRunnerFactory(ForkingTaskRunnerConfig config,
                        TaskConfig taskConfig,
                        WorkerConfig workerConfig,
                        Properties props,
                        com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                        TaskLogPusher persistentTaskLogs,
                        DruidNode node)  | 
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)  | 
ThreadPoolTaskRunner(TaskToolboxFactory toolboxFactory,
                    TaskConfig taskConfig,
                    ServiceEmitter emitter,
                    DruidNode node,
                    ServerConfig serverConfig)  | 
| Constructor and Description | 
|---|
KerberosAuthenticator(String serverPrincipal,
                     String serverKeytab,
                     String internalClientPrincipal,
                     String internalClientKeytab,
                     String authToLocal,
                     List<String> excludedPaths,
                     String cookieSignatureSecret,
                     String authorizerName,
                     DruidNode node)  | 
| Constructor and Description | 
|---|
ServiceAnnouncingChatHandlerProvider(DruidNode node,
                                    ServiceAnnouncer serviceAnnouncer,
                                    ServerConfig serverConfig)  | 
| Modifier and Type | Method and Description | 
|---|---|
DruidNode | 
DruidNode.withService(String service)  | 
| Constructor and Description | 
|---|
DruidBroker(FilteredServerInventoryView serverInventoryView,
           DruidNode self,
           ServiceAnnouncer serviceAnnouncer)  | 
| 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)  | 
| Modifier and Type | Method and Description | 
|---|---|
ServiceEmitter | 
EmitterModule.getServiceEmitter(com.google.common.base.Supplier<DruidNode> configSupplier,
                 Emitter emitter,
                 Map<String,String> extraServiceDimensions)  | 
| Modifier and Type | Method and Description | 
|---|---|
org.eclipse.jetty.server.Server | 
JettyServerModule.getServer(com.google.inject.Injector injector,
         Lifecycle lifecycle,
         DruidNode node,
         ServerConfig config,
         TLSServerConfig TLSServerConfig)  | 
org.eclipse.jetty.server.Server | 
ChatHandlerServerModule.getServer(com.google.inject.Injector injector,
         Lifecycle lifecycle,
         DruidNode node,
         ServerConfig config,
         TLSServerConfig TLSServerConfig)  | 
| Constructor and Description | 
|---|
DruidAvaticaHandler(DruidMeta druidMeta,
                   DruidNode druidNode,
                   AvaticaMonitor avaticaMonitor)  | 
Copyright © 2011–2018. All rights reserved.