io.druid.indexing.overlord

Class ForkingTaskRunner

java.lang.Object

io.druid.indexing.overlord.ForkingTaskRunner

All Implemented Interfaces:

TaskRunner, io.druid.tasklogs.TaskLogStreamer

public class ForkingTaskRunner
extends Object
implements TaskRunner, io.druid.tasklogs.TaskLogStreamer

Runs tasks in separate processes using the "internal peon" verb.

Constructor Summary

Constructors

Constructor and Description
ForkingTaskRunner(ForkingTaskRunnerConfig config, TaskConfig taskConfig, WorkerConfig workerConfig, Properties props, io.druid.tasklogs.TaskLogPusher taskLogPusher, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, DruidNode node)

Method Summary

Methods

Modifier and Type	Method and Description
Collection<TaskRunnerWorkItem>	getKnownTasks()
Collection<TaskRunnerWorkItem>	getPendingTasks()
Collection<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.
void	stop()
com.google.common.base.Optional<com.google.common.io.InputSupplier<InputStream>>	streamTaskLog(String taskid, long offset)

Methods inherited from class java.lang.Object

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

Constructor Detail

ForkingTaskRunner

@Inject
public ForkingTaskRunner(ForkingTaskRunnerConfig config,
                        TaskConfig taskConfig,
                        WorkerConfig workerConfig,
                        Properties props,
                        io.druid.tasklogs.TaskLogPusher taskLogPusher,
                        com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                        DruidNode node)

Method Detail

run

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

Description copied from interface: TaskRunner

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

Specified by:

run in interface TaskRunner

Parameters:

task - task to run

Returns:

task status, eventually

stop

public void stop()

shutdown

public void shutdown(String taskid)

Description copied from interface: TaskRunner

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

Specified by:

shutdown in interface TaskRunner

Parameters:

taskid - task ID to clean up resources for

getRunningTasks

public Collection<TaskRunnerWorkItem> getRunningTasks()

Specified by:

getRunningTasks in interface TaskRunner

getPendingTasks

public Collection<TaskRunnerWorkItem> getPendingTasks()

Specified by:

getPendingTasks in interface TaskRunner

getKnownTasks

public Collection<TaskRunnerWorkItem> getKnownTasks()

Specified by:

getKnownTasks in interface TaskRunner

getWorkers

public Collection<ZkWorker> getWorkers()

Specified by:

getWorkers in interface TaskRunner

streamTaskLog

public com.google.common.base.Optional<com.google.common.io.InputSupplier<InputStream>> streamTaskLog(String taskid,
                                                                                             long offset)

Specified by:

streamTaskLog in interface io.druid.tasklogs.TaskLogStreamer