com.asakusafw.workflow.executor

Interface TaskExecutor

All Known Implementing Classes:

BasicCommandTaskExecutor, BasicDeleteTaskExecutor, BridgeDeleteTaskExecutor, BridgeHadoopTaskExecutor, DefaultCommandTaskExecutor, DefaultDeleteTaskExecutor, DefaultHadoopTaskExecutor, InProcessHadoopTaskExecutor, InProcessWindGateFinalizeTaskExecutor, InProcessWindGateProcessTaskExecutor, VoidDeleteTaskExecutor

public interface TaskExecutor

Executes a TaskInfo.

Since:

0.10.0

Method Summary

Modifier and Type	Method and Description
void	execute(TaskExecutionContext context, TaskInfo task) Executes a task.
boolean	isSupported(TaskExecutionContext context, TaskInfo task) Returns whether this executor supports executing the target task.

Method Detail

isSupported

boolean isSupported(TaskExecutionContext context,
                    TaskInfo task)

Returns whether this executor supports executing the target task.

Parameters:

context - the current context

task - the target task

Returns:

true if this supports the target task, otherwise false

execute

void execute(TaskExecutionContext context,
             TaskInfo task)
      throws InterruptedException,
             IOException

Executes a task.

Parameters:

context - the current context

task - the target task

Throws:

InterruptedException - if interrupted while executing the task

IOException - if task execution was failed