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.