Uses of Class
io.druid.indexing.common.TaskLocation

Packages that use TaskLocation

Package	Description
io.druid.indexing.common
io.druid.indexing.overlord
io.druid.indexing.worker

Uses of TaskLocation in io.druid.indexing.common

Methods in io.druid.indexing.common that return TaskLocation

Modifier and Type	Method and Description
static TaskLocation	TaskLocation.create(String host, int port)
TaskLocation	TaskInfoProvider.getTaskLocation(String id)
static TaskLocation	TaskLocation.unknown()

Uses of TaskLocation in io.druid.indexing.overlord

Methods in io.druid.indexing.overlord that return TaskLocation

Modifier and Type	Method and Description
abstract TaskLocation	TaskRunnerWorkItem.getLocation()
TaskLocation	RemoteTaskRunnerWorkItem.getLocation()

Methods in io.druid.indexing.overlord with parameters of type TaskLocation

Modifier and Type	Method and Description
void	TaskRunnerListener.locationChanged(String taskId, TaskLocation newLocation) Called when the location of a task has changed.
static void	TaskRunnerUtils.notifyLocationChanged(Iterable<Pair<TaskRunnerListener,Executor>> listeners, String taskId, TaskLocation location)
void	RemoteTaskRunnerWorkItem.setLocation(TaskLocation location)
RemoteTaskRunnerWorkItem	RemoteTaskRunnerWorkItem.withWorker(Worker theWorker, TaskLocation location)

Constructors in io.druid.indexing.overlord with parameters of type TaskLocation

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)

Uses of TaskLocation in io.druid.indexing.worker

Methods in io.druid.indexing.worker that return TaskLocation

Modifier and Type	Method and Description
TaskLocation	TaskAnnouncement.getTaskLocation()

Methods in io.druid.indexing.worker with parameters of type TaskLocation

Modifier and Type	Method and Description
static TaskAnnouncement	TaskAnnouncement.create(String taskId, TaskResource resource, TaskStatus status, TaskLocation location)
static TaskAnnouncement	TaskAnnouncement.create(Task task, TaskStatus status, TaskLocation location)