Package | Description |
---|---|
io.druid.curator.discovery | |
io.druid.indexing.overlord | |
io.druid.segment.realtime.firehose | |
io.druid.server.coordination.broker | |
io.druid.server.coordinator |
Modifier and Type | Class and Description |
---|---|
class |
CuratorServiceAnnouncer
Deprecated.
|
class |
NoopServiceAnnouncer
Deprecated.
|
Constructor and Description |
---|
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) |
Constructor and Description |
---|
ServiceAnnouncingChatHandlerProvider(DruidNode node,
ServiceAnnouncer serviceAnnouncer,
ServerConfig serverConfig) |
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) |
Copyright © 2011–2018. All rights reserved.