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