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.kafka
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)

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

Modifier and Type	Method and Description
com.google.common.base.Optional<TaskStatus>	TaskInfoProvider.getTaskStatus(String id)

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.kafka

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

Modifier and Type	Method and Description
TaskStatus	KafkaIndexTask.run(TaskToolbox toolbox)

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)
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()
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)
static void	TaskRunnerUtils.notifyStatusChanged(Iterable<Pair<TaskRunnerListener,Executor>> listeners, String taskId, 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)
void	TaskRunnerListener.statusChanged(String taskId, TaskStatus status) Called when the status of a task has changed.

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, TaskLocation location)
static TaskAnnouncement	TaskAnnouncement.create(Task task, TaskStatus status, TaskLocation location)

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()