io.druid.indexing.overlord

Interface TaskRunner

All Known Implementing Classes:

ForkingTaskRunner, RemoteTaskRunner, ThreadPoolTaskRunner

public interface TaskRunner

Interface for handing off tasks. Managed by a TaskQueue.

Method Summary

Methods

Modifier and Type	Method and Description
Collection<? extends TaskRunnerWorkItem>	getKnownTasks()
Collection<? extends TaskRunnerWorkItem>	getPendingTasks()
Collection<? extends TaskRunnerWorkItem>	getRunningTasks()
Collection<ZkWorker>	getWorkers()
com.google.common.util.concurrent.ListenableFuture<TaskStatus>	run(Task task) Run a task.
void	shutdown(String taskid) Inform the task runner it can clean up any resources associated with a task.

Method Detail

run

com.google.common.util.concurrent.ListenableFuture<TaskStatus> run(Task task)

Run a task. The returned status should be some kind of completed status.

Parameters:

task - task to run

Returns:

task status, eventually

shutdown

void shutdown(String taskid)

Inform the task runner it can clean up any resources associated with a task. This implies shutdown of any currently-running tasks.

Parameters:

taskid - task ID to clean up resources for

getRunningTasks

Collection<? extends TaskRunnerWorkItem> getRunningTasks()

getPendingTasks

Collection<? extends TaskRunnerWorkItem> getPendingTasks()

getKnownTasks

Collection<? extends TaskRunnerWorkItem> getKnownTasks()

getWorkers

Collection<ZkWorker> getWorkers()