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.