Modifier and Type | Method and Description |
---|---|
DruidServerMetadata |
StorageNodeModule.getMetadata(DruidNode node,
NodeTypeConfig nodeType,
DruidServerConfig config) |
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,
IndexerZkConfig zkPaths,
TaskRunnerFactory runnerFactory,
org.apache.curator.framework.CuratorFramework curator,
ServiceAnnouncer serviceAnnouncer,
CoordinatorOverlordServiceConfig coordinatorOverlordServiceConfig,
com.metamx.emitter.service.ServiceEmitter emitter,
SupervisorManager supervisorManager,
OverlordHelperManager overlordHelperManager) |
ThreadPoolTaskRunner(TaskToolboxFactory toolboxFactory,
TaskConfig taskConfig,
com.metamx.emitter.service.ServiceEmitter emitter,
DruidNode node) |
Constructor and Description |
---|
SpnegoFilterHolder(SpnegoFilterConfig config,
DruidNode node) |
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,
com.metamx.emitter.service.ServiceEmitter emitter,
ScheduledExecutorFactory scheduledExecutorFactory,
IndexingServiceClient indexingServiceClient,
LoadQueueTaskMaster taskMaster,
ServiceAnnouncer serviceAnnouncer,
DruidNode self,
Set<DruidCoordinatorHelper> indexingServiceHelpers,
BalancerStrategyFactory factory) |
Modifier and Type | Method and Description |
---|---|
com.metamx.emitter.service.ServiceEmitter |
EmitterModule.getServiceEmitter(com.google.common.base.Supplier<DruidNode> configSupplier,
com.metamx.emitter.core.Emitter emitter) |
Modifier and Type | Method and Description |
---|---|
org.eclipse.jetty.server.Server |
JettyServerModule.getServer(com.google.inject.Injector injector,
Lifecycle lifecycle,
DruidNode node,
ServerConfig config) |
Constructor and Description |
---|
DruidAvaticaHandler(DruidMeta druidMeta,
DruidNode druidNode,
AvaticaMonitor avaticaMonitor) |
Copyright © 2011–2017. All rights reserved.