io.druid.indexing.overlord

Class TaskRunnerWorkItem

java.lang.Object

io.druid.indexing.overlord.TaskRunnerWorkItem

Direct Known Subclasses:

RemoteTaskRunnerWorkItem

public abstract class TaskRunnerWorkItem
extends Object

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

Modifier and Type	Method and Description
org.joda.time.DateTime	getCreatedTime()
abstract TaskLocation	getLocation()
org.joda.time.DateTime	getQueueInsertionTime()
com.google.common.util.concurrent.ListenableFuture<TaskStatus>	getResult()
String	getTaskId()
String	toString()

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

getLocation

public abstract TaskLocation getLocation()

toString

public String toString()

Overrides:

toString in class Object