com.asakusafw.workflow.executor.basic

Class BasicDeleteTaskExecutor

java.lang.Object

com.asakusafw.workflow.executor.basic.BasicDeleteTaskExecutor

All Implemented Interfaces:

TaskExecutor

Direct Known Subclasses:

BridgeDeleteTaskExecutor, DefaultDeleteTaskExecutor

public class BasicDeleteTaskExecutor
extends Object
implements TaskExecutor

A basic implementation of TaskExecutor for DeleteTaskInfo. This implementation does not support Hadoop file system. To support Hadoop file systems, please inherit this class and override deleteOnHadoopFileSystem(TaskExecutionContext, String).

Since:

0.10.0

Constructor Summary

Constructors

Constructor and Description
BasicDeleteTaskExecutor()

Method Summary

Modifier and Type	Method and Description
protected void	deleteOnHadoopFileSystem(TaskExecutionContext context, String path) Delete files on Hadoop file system.
protected void	deleteOnLocalFileSystem(TaskExecutionContext context, String path) Delete files on local file system.
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

Constructor Detail

BasicDeleteTaskExecutor

public BasicDeleteTaskExecutor()

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

deleteOnLocalFileSystem

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

Delete files on local file system.

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

deleteOnHadoopFileSystem

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

Delete files on Hadoop file system.

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