Package | Description |
---|---|
io.druid.client | |
io.druid.indexing.overlord | |
io.druid.indexing.worker | |
io.druid.server.bridge | |
io.druid.server.coordination | |
io.druid.server.coordinator |
Constructor and Description |
---|
BatchServerInventoryView(ZkPathsConfig zkPaths,
org.apache.curator.framework.CuratorFramework curator,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.google.common.base.Predicate<io.druid.timeline.DataSegment> defaultFilter) |
SingleServerInventoryView(ZkPathsConfig zkPaths,
org.apache.curator.framework.CuratorFramework curator,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.google.common.base.Predicate<io.druid.timeline.DataSegment> defaultFilter) |
Constructor and Description |
---|
RemoteTaskRunner(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
RemoteTaskRunnerConfig config,
ZkPathsConfig zkPaths,
org.apache.curator.framework.CuratorFramework cf,
PathChildrenCacheFactory pathChildrenCacheFactory,
com.metamx.http.client.HttpClient httpClient,
com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef) |
RemoteTaskRunnerFactory(org.apache.curator.framework.CuratorFramework curator,
RemoteTaskRunnerConfig remoteTaskRunnerConfig,
ZkPathsConfig zkPaths,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
com.metamx.http.client.HttpClient httpClient,
com.google.common.base.Supplier<WorkerBehaviorConfig> workerConfigRef) |
TaskMaster(TaskQueueConfig taskQueueConfig,
TaskLockbox taskLockbox,
TaskStorage taskStorage,
TaskActionClientFactory taskActionClientFactory,
DruidNode node,
ZkPathsConfig zkPaths,
TaskRunnerFactory runnerFactory,
ResourceManagementSchedulerFactory managementSchedulerFactory,
org.apache.curator.framework.CuratorFramework curator,
ServiceAnnouncer serviceAnnouncer,
com.metamx.emitter.service.ServiceEmitter emitter) |
Constructor and Description |
---|
WorkerCuratorCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
ZkPathsConfig zkPaths,
RemoteTaskRunnerConfig config,
org.apache.curator.framework.CuratorFramework curatorFramework,
Worker worker) |
Modifier and Type | Class and Description |
---|---|
class |
DruidClusterBridgeConfig |
Constructor and Description |
---|
BridgeZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
ZkPathsConfig zkPaths,
SegmentLoaderConfig config,
DruidServerMetadata me,
org.apache.curator.framework.CuratorFramework curator,
DbSegmentPublisher dbSegmentPublisher,
DatabaseSegmentManager databaseSegmentManager,
ServerView serverView) |
Constructor and Description |
---|
AbstractDataSegmentAnnouncer(DruidServerMetadata server,
ZkPathsConfig config,
Announcer announcer,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
BaseZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
ZkPathsConfig zkPaths,
SegmentLoaderConfig config,
DruidServerMetadata me,
org.apache.curator.framework.CuratorFramework curator) |
BatchDataSegmentAnnouncer(DruidServerMetadata server,
BatchDataSegmentAnnouncerConfig config,
ZkPathsConfig zkPaths,
Announcer announcer,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
SingleDataSegmentAnnouncer(DruidServerMetadata server,
ZkPathsConfig config,
Announcer announcer,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
ZkCoordinator(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
SegmentLoaderConfig config,
ZkPathsConfig zkPaths,
DruidServerMetadata me,
DataSegmentAnnouncer announcer,
org.apache.curator.framework.CuratorFramework curator,
ServerManager serverManager,
com.metamx.common.concurrent.ScheduledExecutorFactory factory) |
Constructor and Description |
---|
DruidCoordinator(DruidCoordinatorConfig config,
ZkPathsConfig zkPaths,
JacksonConfigManager configManager,
DatabaseSegmentManager databaseSegmentManager,
ServerInventoryView serverInventoryView,
DatabaseRuleManager databaseRuleManager,
org.apache.curator.framework.CuratorFramework curator,
com.metamx.emitter.service.ServiceEmitter emitter,
com.metamx.common.concurrent.ScheduledExecutorFactory scheduledExecutorFactory,
IndexingServiceClient indexingServiceClient,
LoadQueueTaskMaster taskMaster,
ServiceAnnouncer serviceAnnouncer,
DruidNode self) |
Copyright © 2015. All rights reserved.