Uses of Interface
io.druid.indexing.common.actions.TaskActionClient

Packages that use TaskActionClient

Package	Description
io.druid.indexing.appenderator
io.druid.indexing.common
io.druid.indexing.common.actions
io.druid.indexing.common.task
io.druid.indexing.kafka
io.druid.indexing.overlord

Uses of TaskActionClient in io.druid.indexing.appenderator

Constructors in io.druid.indexing.appenderator with parameters of type TaskActionClient

Constructor and Description
ActionBasedSegmentAllocator(TaskActionClient taskActionClient, DataSchema dataSchema)
ActionBasedUsedSegmentChecker(TaskActionClient taskActionClient)

Uses of TaskActionClient in io.druid.indexing.common

Methods in io.druid.indexing.common that return TaskActionClient

Modifier and Type	Method and Description
TaskActionClient	TaskToolbox.getTaskActionClient()

Constructors in io.druid.indexing.common with parameters of type TaskActionClient

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)

Uses of TaskActionClient in io.druid.indexing.common.actions

Classes in io.druid.indexing.common.actions that implement TaskActionClient

Modifier and Type	Class and Description
class	LocalTaskActionClient
class	RemoteTaskActionClient

Methods in io.druid.indexing.common.actions that return TaskActionClient

Modifier and Type	Method and Description
TaskActionClient	TaskActionClientFactory.create(Task task)
TaskActionClient	RemoteTaskActionClientFactory.create(Task task)
TaskActionClient	LocalTaskActionClientFactory.create(Task task)

Uses of TaskActionClient in io.druid.indexing.common.task

Methods in io.druid.indexing.common.task with parameters of type TaskActionClient

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	CompactionTask.isReady(TaskActionClient taskActionClient)
boolean	AbstractFixedIntervalTask.isReady(TaskActionClient taskActionClient)
static Map<org.joda.time.Interval,TaskLock>	Tasks.tryAcquireExclusiveLocks(TaskActionClient client, SortedSet<org.joda.time.Interval> intervals)

Uses of TaskActionClient in io.druid.indexing.kafka

Methods in io.druid.indexing.kafka with parameters of type TaskActionClient

Modifier and Type	Method and Description
boolean	KafkaIndexTask.isReady(TaskActionClient taskActionClient)

Uses of TaskActionClient in io.druid.indexing.overlord

Methods in io.druid.indexing.overlord that return types with arguments of type TaskActionClient

Modifier and Type	Method and Description
com.google.common.base.Optional<TaskActionClient>	TaskMaster.getTaskActionClient(Task task)