io.druid.indexing.overlord

Class TaskRunnerWorkItem

java.lang.Object

io.druid.indexing.overlord.TaskRunnerWorkItem

All Implemented Interfaces:

Comparable<TaskRunnerWorkItem>

Direct Known Subclasses:

RemoteTaskRunnerWorkItem

public class TaskRunnerWorkItem
extends Object
implements Comparable<TaskRunnerWorkItem>

A holder for a task and different components associated with the task

Constructor Summary

Constructors

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)

Method Summary

Methods

Modifier and Type	Method and Description
int	compareTo(TaskRunnerWorkItem taskRunnerWorkItem)
org.joda.time.DateTime	getCreatedTime()
org.joda.time.DateTime	getQueueInsertionTime()
com.google.common.util.concurrent.ListenableFuture<TaskStatus>	getResult()
String	getTaskId()
String	toString()
TaskRunnerWorkItem	withQueueInsertionTime(org.joda.time.DateTime time)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskRunnerWorkItem

public TaskRunnerWorkItem(String taskId,
                  com.google.common.util.concurrent.ListenableFuture<TaskStatus> result)

TaskRunnerWorkItem

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

Method Detail

getTaskId

public String getTaskId()

getResult

public com.google.common.util.concurrent.ListenableFuture<TaskStatus> getResult()

getCreatedTime

public org.joda.time.DateTime getCreatedTime()

getQueueInsertionTime

public org.joda.time.DateTime getQueueInsertionTime()

withQueueInsertionTime

public TaskRunnerWorkItem withQueueInsertionTime(org.joda.time.DateTime time)

compareTo

public int compareTo(TaskRunnerWorkItem taskRunnerWorkItem)

Specified by:

compareTo in interface Comparable<TaskRunnerWorkItem>

toString

public String toString()

Overrides:

toString in class Object