| Package | Description | 
|---|---|
| io.druid.indexing.common | |
| io.druid.indexing.overlord | |
| io.druid.indexing.worker.executor | 
| Modifier and Type | Method and Description | 
|---|---|
TaskConfig | 
TaskToolbox.getConfig()  | 
| 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)  | 
ThreadPoolTaskRunner(TaskToolboxFactory toolboxFactory,
                    TaskConfig taskConfig,
                    ServiceEmitter emitter,
                    DruidNode node,
                    ServerConfig serverConfig)  | 
| Constructor and Description | 
|---|
ExecutorLifecycle(ExecutorLifecycleConfig taskExecutorConfig,
                 TaskConfig taskConfig,
                 TaskActionClientFactory taskActionClientFactory,
                 TaskRunner taskRunner,
                 com.fasterxml.jackson.databind.ObjectMapper jsonMapper)  | 
Copyright © 2011–2018. All rights reserved.