| Package | Description | 
|---|---|
| io.druid.indexing.common | |
| io.druid.indexing.common.actions | |
| io.druid.indexing.overlord | |
| io.druid.indexing.worker.executor | 
| Constructor and Description | 
|---|
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)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
LocalTaskActionClientFactory  | 
class  | 
RemoteTaskActionClientFactory  | 
| 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)  | 
TaskQueue(TaskQueueConfig config,
         TaskStorage taskStorage,
         TaskRunner taskRunner,
         TaskActionClientFactory taskActionClientFactory,
         TaskLockbox taskLockbox,
         ServiceEmitter emitter)  | 
| Constructor and Description | 
|---|
ExecutorLifecycle(ExecutorLifecycleConfig taskExecutorConfig,
                 TaskConfig taskConfig,
                 TaskActionClientFactory taskActionClientFactory,
                 TaskRunner taskRunner,
                 com.fasterxml.jackson.databind.ObjectMapper jsonMapper)  | 
Copyright © 2011–2018. All rights reserved.