Uses of Interface
io.druid.indexing.common.task.Task

Packages that use Task

Package	Description
io.druid.indexing.common
io.druid.indexing.common.actions
io.druid.indexing.common.task
io.druid.indexing.kafka
io.druid.indexing.overlord
io.druid.indexing.overlord.http
io.druid.indexing.overlord.setup
io.druid.indexing.worker

Uses of Task in io.druid.indexing.common

Methods in io.druid.indexing.common with parameters of type Task

Modifier and Type	Method and Description
TaskToolbox	TaskToolboxFactory.build(Task task)

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

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

Modifier and Type	Method and Description
Task	TaskActionHolder.getTask()

Methods in io.druid.indexing.common.actions with parameters of type Task

Modifier and Type	Method and Description
TaskActionClient	TaskActionClientFactory.create(Task task)
TaskActionClient	RemoteTaskActionClientFactory.create(Task task)
TaskActionClient	LocalTaskActionClientFactory.create(Task task)
RetType	TaskAction.perform(Task task, TaskActionToolbox toolbox)
SegmentPublishResult	SegmentTransactionalInsertAction.perform(Task task, TaskActionToolbox toolbox) Behaves similarly to IndexerMetadataStorageCoordinator.announceHistoricalSegments(Set, DataSourceMetadata, DataSourceMetadata).
Void	SegmentNukeAction.perform(Task task, TaskActionToolbox toolbox)
Void	SegmentMetadataUpdateAction.perform(Task task, TaskActionToolbox toolbox)
List<DataSegment>	SegmentListUsedAction.perform(Task task, TaskActionToolbox toolbox)
List<DataSegment>	SegmentListUnusedAction.perform(Task task, TaskActionToolbox toolbox)
Set<DataSegment>	SegmentInsertAction.perform(Task task, TaskActionToolbox toolbox) Behaves similarly to IndexerMetadataStorageCoordinator.announceHistoricalSegments(java.util.Set<io.druid.timeline.DataSegment>), with startMetadata and endMetadata both null.
SegmentIdentifier	SegmentAllocateAction.perform(Task task, TaskActionToolbox toolbox)
Boolean	ResetDataSourceMetadataAction.perform(Task task, TaskActionToolbox toolbox)
TaskLock	LockTryAcquireAction.perform(Task task, TaskActionToolbox toolbox)
Void	LockReleaseAction.perform(Task task, TaskActionToolbox toolbox)
List<TaskLock>	LockListAction.perform(Task task, TaskActionToolbox toolbox)
TaskLock	LockAcquireAction.perform(Task task, TaskActionToolbox toolbox)
Boolean	CheckPointDataSourceMetadataAction.perform(Task task, TaskActionToolbox toolbox)

Constructors in io.druid.indexing.common.actions with parameters of type Task

Constructor and Description
LocalTaskActionClient(Task task, TaskStorage storage, TaskActionToolbox toolbox)
RemoteTaskActionClient(Task task, DruidLeaderClient druidLeaderClient, RetryPolicyFactory retryPolicyFactory, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
TaskActionHolder(Task task, TaskAction action)

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

Classes in io.druid.indexing.common.task that implement Task

Modifier and Type	Class and Description
class	AbstractFixedIntervalTask
class	AbstractTask
class	AppendTask
class	ArchiveTask
class	CompactionTask
class	ConvertSegmentBackwardsCompatibleTask Deprecated.
static class	ConvertSegmentBackwardsCompatibleTask.SubTask Deprecated.
class	ConvertSegmentTask This task takes a segment and attempts to reindex it in the latest version with the specified indexSpec.
static class	ConvertSegmentTask.SubTask
class	HadoopConverterTask
static class	HadoopConverterTask.ConverterSubTask
class	HadoopIndexTask
class	HadoopTask
class	IndexTask
class	KillTask
class	MergeTask
class	MergeTaskBase
class	MoveTask
class	NoopTask
class	RealtimeIndexTask
class	RestoreTask
class	SameIntervalMergeTask
static class	SameIntervalMergeTask.SubTask

Methods in io.druid.indexing.common.task that return types with arguments of type Task

Modifier and Type	Method and Description
protected Iterable<Task>	HadoopConverterTask.generateSubTasks(String groupId, Iterable<DataSegment> segments, IndexSpec indexSpec, boolean force, boolean validate, Map<String,Object> context)
protected Iterable<Task>	ConvertSegmentTask.generateSubTasks(String groupId, Iterable<DataSegment> segments, IndexSpec indexSpec, boolean force, boolean validate, Map<String,Object> context)

Uses of Task in io.druid.indexing.kafka

Classes in io.druid.indexing.kafka that implement Task

Modifier and Type	Class and Description
class	KafkaIndexTask

Uses of Task in io.druid.indexing.overlord

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

Modifier and Type	Method and Description
List<Task>	TaskStorageQueryAdapter.getActiveTasks()
List<Task>	TaskStorage.getActiveTasks() Returns a list of currently running or pending tasks as stored in the storage facility.
List<Task>	MetadataTaskStorage.getActiveTasks()
List<Task>	HeapMemoryTaskStorage.getActiveTasks()
Collection<Task>	WorkerTaskRunner.getPendingTaskPayloads()
Collection<Task>	RemoteTaskRunner.getPendingTaskPayloads()
com.google.common.base.Optional<Task>	TaskStorageQueryAdapter.getTask(String taskid)
com.google.common.base.Optional<Task>	TaskStorage.getTask(String taskid) Returns task as stored in the storage facility.
com.google.common.base.Optional<Task>	MetadataTaskStorage.getTask(String taskId)
com.google.common.base.Optional<Task>	HeapMemoryTaskStorage.getTask(String taskid)
List<Pair<Task,com.google.common.util.concurrent.ListenableFuture<TaskStatus>>>	ThreadPoolTaskRunner.restore()
List<Pair<Task,com.google.common.util.concurrent.ListenableFuture<TaskStatus>>>	TaskRunner.restore() Some task runners can restart previously-running tasks after being bounced.
List<Pair<Task,com.google.common.util.concurrent.ListenableFuture<TaskStatus>>>	RemoteTaskRunner.restore()
List<Pair<Task,com.google.common.util.concurrent.ListenableFuture<TaskStatus>>>	ForkingTaskRunner.restore()

Methods in io.druid.indexing.overlord with parameters of type Task

Modifier and Type	Method and Description
boolean	TaskQueue.add(Task task) Adds some work to the queue and the underlying task storage facility with a generic "running" status.
void	TaskLockbox.add(Task task)
<T> void	TaskStorage.addAuditLog(Task task, TaskAction<T> taskAction) Add an action taken by a task to the audit log.
<T> void	MetadataTaskStorage.addAuditLog(Task task, TaskAction<T> taskAction)
<T> void	HeapMemoryTaskStorage.addAuditLog(Task task, TaskAction<T> taskAction)
boolean	ImmutableWorkerInfo.canRunTask(Task task)
<T> T	TaskLockbox.doInCriticalSection(Task task, List<org.joda.time.Interval> intervals, CriticalAction<T> action) Perform the given action with a guarantee that the locks of the task are not revoked in the middle of action.
List<TaskLock>	TaskLockbox.findLocksForTask(Task task) Return the currently-active locks for some task.
com.google.common.base.Optional<TaskActionClient>	TaskMaster.getTaskActionClient(Task task)
void	TaskStorage.insert(Task task, TaskStatus status) Adds a task to the storage facility with a particular status.
void	MetadataTaskStorage.insert(Task task, TaskStatus status)
void	HeapMemoryTaskStorage.insert(Task task, TaskStatus status)
LockResult	TaskLockbox.lock(TaskLockType lockType, Task task, org.joda.time.Interval interval) Acquires a lock on behalf of a task.
LockResult	TaskLockbox.lock(TaskLockType lockType, Task task, org.joda.time.Interval interval, long timeoutMs) Acquires a lock on behalf of a task, waiting up to the specified wait time if necessary.
void	TaskLockbox.remove(Task task) Release all locks for a task and remove task from set of active tasks.
com.google.common.util.concurrent.ListenableFuture<TaskStatus>	ThreadPoolTaskRunner.run(Task task)
com.google.common.util.concurrent.ListenableFuture<TaskStatus>	TaskRunner.run(Task task) Run a task.
com.google.common.util.concurrent.ListenableFuture<TaskStatus>	RemoteTaskRunner.run(Task task) A task will be run only if there is no current knowledge in the RemoteTaskRunner of the task.
com.google.common.util.concurrent.ListenableFuture<TaskStatus>	ForkingTaskRunner.run(Task task)
LockResult	TaskLockbox.tryLock(TaskLockType lockType, Task task, org.joda.time.Interval interval) Attempt to acquire a lock for a task, without removing it from the queue.
void	TaskLockbox.unlock(Task task, org.joda.time.Interval interval) Release lock held for a task on a particular interval.

Uses of Task in io.druid.indexing.overlord.http

Methods in io.druid.indexing.overlord.http with parameters of type Task

Modifier and Type	Method and Description
javax.ws.rs.core.Response	OverlordResource.taskPost(Task task, javax.servlet.http.HttpServletRequest req)

Uses of Task in io.druid.indexing.overlord.setup

Methods in io.druid.indexing.overlord.setup with parameters of type Task

Modifier and Type	Method and Description
String	JavaScriptWorkerSelectStrategy.SelectorFunction.apply(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
ImmutableWorkerInfo	WorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task) Customizable logic for selecting a worker to run a task.
ImmutableWorkerInfo	JavaScriptWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
ImmutableWorkerInfo	FillCapacityWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
ImmutableWorkerInfo	EqualDistributionWorkerSelectStrategy.findWorkerForTask(WorkerTaskRunnerConfig config, com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo> zkWorkers, Task task)
static ImmutableWorkerInfo	WorkerSelectUtils.selectWorker(Task task, Map<String,ImmutableWorkerInfo> allWorkers, WorkerTaskRunnerConfig workerTaskRunnerConfig, AffinityConfig affinityConfig, Function<com.google.common.collect.ImmutableMap<String,ImmutableWorkerInfo>,ImmutableWorkerInfo> workerSelector) Helper for WorkerSelectStrategy implementations.

Uses of Task in io.druid.indexing.worker

Methods in io.druid.indexing.worker with parameters of type Task

Modifier and Type	Method and Description
static TaskAnnouncement	TaskAnnouncement.create(Task task, TaskStatus status, TaskLocation location)