com.asakusafw.workflow.hadoop

Class BridgeDeleteTaskExecutor

java.lang.Object

com.asakusafw.workflow.executor.basic.BasicDeleteTaskExecutor

com.asakusafw.workflow.hadoop.BridgeDeleteTaskExecutor

All Implemented Interfaces:

TaskExecutor

public class BridgeDeleteTaskExecutor
extends BasicDeleteTaskExecutor

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

Since:

0.10.0

Field Summary

Fields

Modifier and Type	Field and Description
static String	DELEGATE_CLASS The target class name.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	deleteOnHadoopFileSystem(TaskExecutionContext context, String path) Delete files on Hadoop file system.
boolean	isSupported(TaskExecutionContext context, TaskInfo task) Returns whether this executor supports executing the target task.

Methods inherited from class com.asakusafw.workflow.executor.basic.BasicDeleteTaskExecutor

deleteOnLocalFileSystem, execute

Methods inherited from class java.lang.Object

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

Field Detail

DELEGATE_CLASS

public static final String DELEGATE_CLASS

The target class name.

Constructor Detail

BridgeDeleteTaskExecutor

public BridgeDeleteTaskExecutor()

Creates a new instance.

BridgeDeleteTaskExecutor

public BridgeDeleteTaskExecutor(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

Overrides:

isSupported in class BasicDeleteTaskExecutor

Parameters:

context - the current context

task - the target task

Returns:

true if this supports the target task, otherwise false

deleteOnHadoopFileSystem

protected void deleteOnHadoopFileSystem(TaskExecutionContext context,
                                        String path)
                                 throws IOException,
                                        InterruptedException

Description copied from class: BasicDeleteTaskExecutor

Delete files on Hadoop file system.

Overrides:

deleteOnHadoopFileSystem in class BasicDeleteTaskExecutor

Parameters:

context - the current context

path - the target path

Throws:

IOException - if I/O error was occurred while deleting files

InterruptedException - if interrupted while deleting files