Uses of Class
io.druid.indexing.common.TaskStatus

Packages that use TaskStatus

Package	Description
io.druid.indexing.common
io.druid.indexing.common.task
io.druid.indexing.overlord
io.druid.indexing.worker
io.druid.testing.clients

Uses of TaskStatus in io.druid.indexing.common

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

Modifier and Type	Method and Description
static TaskStatus	TaskStatus.failure(String taskId)
static TaskStatus	TaskStatus.fromCode(String taskId, TaskStatus.Status code)
static TaskStatus	TaskStatus.running(String taskId)
static TaskStatus	TaskStatus.success(String taskId)
TaskStatus	TaskStatus.withDuration(long _duration)

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

Methods in io.druid.indexing.common.task that return TaskStatus

Modifier and Type	Method and Description
TaskStatus	Task.run(TaskToolbox toolbox) Execute a task.
TaskStatus	RestoreTask.run(TaskToolbox toolbox)
TaskStatus	RealtimeIndexTask.run(TaskToolbox toolbox)
TaskStatus	NoopTask.run(TaskToolbox toolbox)
TaskStatus	MoveTask.run(TaskToolbox toolbox)
TaskStatus	MergeTaskBase.run(TaskToolbox toolbox)
TaskStatus	KillTask.run(TaskToolbox toolbox)
TaskStatus	IndexTask.run(TaskToolbox toolbox)
TaskStatus	HadoopIndexTask.run(TaskToolbox toolbox)
TaskStatus	HadoopConverterTask.ConverterSubTask.run(TaskToolbox toolbox)
TaskStatus	ConvertSegmentTask.run(TaskToolbox toolbox)
TaskStatus	ConvertSegmentTask.SubTask.run(TaskToolbox toolbox)
TaskStatus	ArchiveTask.run(TaskToolbox toolbox)
TaskStatus	AbstractTask.success()

Uses of TaskStatus in io.druid.indexing.overlord

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

Modifier and Type	Method and Description
List<TaskStatus>	TaskStorageQueryAdapter.getRecentlyFinishedTaskStatuses()
List<TaskStatus>	TaskStorage.getRecentlyFinishedTaskStatuses() Returns a list of recently finished task statuses as stored in the storage facility.
List<TaskStatus>	MetadataTaskStorage.getRecentlyFinishedTaskStatuses()
List<TaskStatus>	HeapMemoryTaskStorage.getRecentlyFinishedTaskStatuses()
com.google.common.util.concurrent.ListenableFuture<TaskStatus>	TaskRunnerWorkItem.getResult()
com.google.common.base.Optional<TaskStatus>	TaskStorageQueryAdapter.getStatus(String taskid)
com.google.common.base.Optional<TaskStatus>	TaskStorage.getStatus(String taskid) Returns task status as stored in the storage facility.
com.google.common.base.Optional<TaskStatus>	MetadataTaskStorage.getStatus(String taskId)
com.google.common.base.Optional<TaskStatus>	HeapMemoryTaskStorage.getStatus(String taskid)
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)

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

Modifier and Type	Method and Description
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)
void	RemoteTaskRunnerWorkItem.setResult(TaskStatus status)
void	TaskStorage.setStatus(TaskStatus status) Persists task status in the storage facility.
void	MetadataTaskStorage.setStatus(TaskStatus status)
void	HeapMemoryTaskStorage.setStatus(TaskStatus status)

Constructor parameters in io.druid.indexing.overlord with type arguments of type TaskStatus

Constructor and Description
TaskRunnerWorkItem(String taskId, com.google.common.util.concurrent.ListenableFuture<TaskStatus> result)
TaskRunnerWorkItem(String taskId, com.google.common.util.concurrent.ListenableFuture<TaskStatus> result, org.joda.time.DateTime createdTime, org.joda.time.DateTime queueInsertionTime)

Uses of TaskStatus in io.druid.indexing.worker

Methods in io.druid.indexing.worker that return TaskStatus

Modifier and Type	Method and Description
TaskStatus	TaskAnnouncement.getTaskStatus()

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

Modifier and Type	Method and Description
static TaskAnnouncement	TaskAnnouncement.create(String taskId, TaskResource resource, TaskStatus status)
static TaskAnnouncement	TaskAnnouncement.create(Task task, TaskStatus status)

Uses of TaskStatus in io.druid.testing.clients

Methods in io.druid.testing.clients that return TaskStatus

Modifier and Type	Method and Description
TaskStatus	TaskResponseObject.getStatus()