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,
Task task,
TaskActionClient taskActionClient,
com.metamx.emitter.service.ServiceEmitter emitter,
DataSegmentPusher segmentPusher,
DataSegmentKiller dataSegmentKiller,
DataSegmentMover dataSegmentMover,
DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
SegmentHandoffNotifierFactory handoffNotifierFactory,
QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate,
ExecutorService queryExecutorService,
com.metamx.metrics.MonitorScheduler monitorScheduler,
SegmentLoader segmentLoader,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
File taskWorkDir,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
IndexMergerV9 indexMergerV9) |
TaskToolboxFactory(TaskConfig config,
TaskActionClientFactory taskActionClientFactory,
com.metamx.emitter.service.ServiceEmitter emitter,
DataSegmentPusher segmentPusher,
DataSegmentKiller dataSegmentKiller,
DataSegmentMover dataSegmentMover,
DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
SegmentHandoffNotifierFactory handoffNotifierFactory,
QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate,
ExecutorService queryExecutorService,
com.metamx.metrics.MonitorScheduler monitorScheduler,
SegmentLoaderFactory segmentLoaderFactory,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
IndexMergerV9 indexMergerV9) |
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,
com.metamx.emitter.service.ServiceEmitter emitter,
DruidNode node) |
Constructor and Description |
---|
ExecutorLifecycle(ExecutorLifecycleConfig taskExecutorConfig,
TaskConfig taskConfig,
TaskActionClientFactory taskActionClientFactory,
TaskRunner taskRunner,
com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Copyright © 2011–2017. All rights reserved.