Constructor and Description |
---|
ActionBasedSegmentAllocator(TaskActionClient taskActionClient,
DataSchema dataSchema) |
ActionBasedUsedSegmentChecker(TaskActionClient taskActionClient) |
Modifier and Type | Method and Description |
---|---|
TaskActionClient |
TaskToolbox.getTaskActionClient() |
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) |
Modifier and Type | Class and Description |
---|---|
class |
LocalTaskActionClient |
class |
RemoteTaskActionClient |
Modifier and Type | Method and Description |
---|---|
TaskActionClient |
TaskActionClientFactory.create(Task task) |
TaskActionClient |
RemoteTaskActionClientFactory.create(Task task) |
TaskActionClient |
LocalTaskActionClientFactory.create(Task task) |
Modifier and Type | Method and Description |
---|---|
boolean |
Task.isReady(TaskActionClient taskActionClient)
Execute preflight actions for a task.
|
boolean |
RealtimeIndexTask.isReady(TaskActionClient taskActionClient) |
boolean |
NoopTask.isReady(TaskActionClient taskActionClient) |
boolean |
MergeTaskBase.isReady(TaskActionClient taskActionClient)
Checks pre-existing segments in "context" to confirm that this merge query is valid.
|
boolean |
IndexTask.isReady(TaskActionClient taskActionClient) |
boolean |
HadoopIndexTask.isReady(TaskActionClient taskActionClient) |
boolean |
HadoopConverterTask.ConverterSubTask.isReady(TaskActionClient taskActionClient) |
boolean |
AbstractFixedIntervalTask.isReady(TaskActionClient taskActionClient) |
Modifier and Type | Method and Description |
---|---|
boolean |
KafkaIndexTask.isReady(TaskActionClient taskActionClient) |
Modifier and Type | Method and Description |
---|---|
com.google.common.base.Optional<TaskActionClient> |
TaskMaster.getTaskActionClient(Task task) |
Copyright © 2011–2017. All rights reserved.