com.asakusafw.workflow.hadoop

Class BridgeHadoopTaskExecutor

java.lang.Object

com.asakusafw.workflow.hadoop.BridgeHadoopTaskExecutor

All Implemented Interfaces:

TaskExecutor

public class BridgeHadoopTaskExecutor
extends Object
implements TaskExecutor

Executes hadoop tasks via tools/bin/libexec/workflow/hadoop-bridge.

Since:

0.10.0

Field Summary

Fields

Modifier and Type	Field and Description
static String	LAUNCHER_CLASS The Asakusa application launcher class name.

Constructor Summary

Constructors

Constructor and Description
BridgeHadoopTaskExecutor() Creates a new instance.
BridgeHadoopTaskExecutor(Function<? super TaskExecutionContext,? extends CommandLauncher> launchers) Creates a new instance.

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.

Methods inherited from class java.lang.Object

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

Field Detail

LAUNCHER_CLASS

public static final String LAUNCHER_CLASS

The Asakusa application launcher class name.

See Also:

Constant Field Values

Constructor Detail

BridgeHadoopTaskExecutor

public BridgeHadoopTaskExecutor()

Creates a new instance.

BridgeHadoopTaskExecutor

public BridgeHadoopTaskExecutor(Function<? super TaskExecutionContext,? extends CommandLauncher> launchers)

Creates a new instance.

Parameters:

launchers - the launcher provider

Method Detail

isSupported

public boolean isSupported(TaskExecutionContext context,
                           TaskInfo task)

Description copied from interface: TaskExecutor

Returns whether this executor supports executing the target task.

Specified by:

isSupported in interface TaskExecutor

Parameters:

context - the current context

task - the target task

Returns:

true if this supports the target task, otherwise false

execute

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

Description copied from interface: TaskExecutor

Executes a task.

Specified by:

execute in interface TaskExecutor

Parameters:

context - the current context

task - the target task

Throws:

IOException - if task execution was failed

InterruptedException - if interrupted while executing the task