io.druid.indexing.overlord

Class RemoteTaskRunnerWorkItem

java.lang.Object

io.druid.indexing.overlord.TaskRunnerWorkItem

io.druid.indexing.overlord.RemoteTaskRunnerWorkItem

public class RemoteTaskRunnerWorkItem
extends TaskRunnerWorkItem

Constructor Summary

Constructors

Constructor and Description
RemoteTaskRunnerWorkItem(String taskId, org.joda.time.DateTime createdTime, org.joda.time.DateTime queueInsertionTime, Worker worker, TaskLocation location)
RemoteTaskRunnerWorkItem(String taskId, Worker worker, TaskLocation location)

Method Summary

Modifier and Type	Method and Description
TaskLocation	getLocation()
Worker	getWorker()
void	setLocation(TaskLocation location)
void	setResult(TaskStatus status)
RemoteTaskRunnerWorkItem	withQueueInsertionTime(org.joda.time.DateTime time)
RemoteTaskRunnerWorkItem	withWorker(Worker theWorker, TaskLocation location)

Methods inherited from class io.druid.indexing.overlord.TaskRunnerWorkItem

getCreatedTime, getQueueInsertionTime, getResult, getTaskId, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteTaskRunnerWorkItem

public RemoteTaskRunnerWorkItem(String taskId,
                                Worker worker,
                                TaskLocation location)

RemoteTaskRunnerWorkItem

public RemoteTaskRunnerWorkItem(String taskId,
                                org.joda.time.DateTime createdTime,
                                org.joda.time.DateTime queueInsertionTime,
                                Worker worker,
                                TaskLocation location)

Method Detail

setLocation

public void setLocation(TaskLocation location)

getLocation

public TaskLocation getLocation()

Specified by:

getLocation in class TaskRunnerWorkItem

getWorker

public Worker getWorker()

setResult

public void setResult(TaskStatus status)

withQueueInsertionTime

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

withWorker

public RemoteTaskRunnerWorkItem withWorker(Worker theWorker,
                                           TaskLocation location)