io.druid.indexing.overlord

Class RemoteTaskRunnerWorkItem

java.lang.Object

io.druid.indexing.overlord.TaskRunnerWorkItem

io.druid.indexing.overlord.RemoteTaskRunnerWorkItem

All Implemented Interfaces:

Comparable<TaskRunnerWorkItem>

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)
RemoteTaskRunnerWorkItem(String taskId, Worker worker)

Method Summary

Methods

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

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

compareTo, 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)

RemoteTaskRunnerWorkItem

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

Method Detail

getWorker

public Worker getWorker()

setResult

public void setResult(TaskStatus status)

withQueueInsertionTime

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

Overrides:

withQueueInsertionTime in class TaskRunnerWorkItem

withWorker

public RemoteTaskRunnerWorkItem withWorker(Worker theWorker)