io.druid.indexing.common

Class TaskStatus

java.lang.Object

io.druid.indexing.common.TaskStatus

public class TaskStatus
extends Object

Represents the status of a task from the perspective of the coordinator. The task may be ongoing (isComplete() false) or it may be complete (isComplete() true). TaskStatus objects are immutable.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TaskStatus.Status

Method Summary

Methods

Modifier and Type	Method and Description
static TaskStatus	failure(String taskId)
static TaskStatus	fromCode(String taskId, TaskStatus.Status code)
long	getDuration()
String	getId()
TaskStatus.Status	getStatusCode()
boolean	isComplete() Inverse of isRunnable().
boolean	isFailure() Returned by tasks when they complete unsuccessfully.
boolean	isRunnable() Signals that a task is not yet complete, and is still runnable on a worker.
boolean	isSuccess() Returned by tasks when they spawn subtasks.
static TaskStatus	running(String taskId)
static TaskStatus	success(String taskId)
String	toString()
TaskStatus	withDuration(long _duration)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

running

public static TaskStatus running(String taskId)

success

public static TaskStatus success(String taskId)

failure

public static TaskStatus failure(String taskId)

fromCode

public static TaskStatus fromCode(String taskId,
                  TaskStatus.Status code)

getId

public String getId()

getStatusCode

public TaskStatus.Status getStatusCode()

getDuration

public long getDuration()

isRunnable

public boolean isRunnable()

Signals that a task is not yet complete, and is still runnable on a worker. Exactly one of isRunnable, isSuccess, or isFailure will be true at any one time.

Returns:

whether the task is runnable.

isComplete

public boolean isComplete()

Inverse of isRunnable().

Returns:

whether the task is complete.

isSuccess

public boolean isSuccess()

Returned by tasks when they spawn subtasks. Exactly one of isRunnable, isSuccess, or isFailure will be true at any one time.

Returns:

whether the task succeeded.

isFailure

public boolean isFailure()

Returned by tasks when they complete unsuccessfully. Exactly one of isRunnable, isSuccess, or isFailure will be true at any one time.

Returns:

whether the task failed

withDuration

public TaskStatus withDuration(long _duration)

toString

public String toString()

Overrides:

toString in class Object