com.asakusafw.testdriver.executor

Class DefaultDeleteTaskExecutor

java.lang.Object

com.asakusafw.workflow.executor.basic.BasicDeleteTaskExecutor

com.asakusafw.testdriver.executor.DefaultDeleteTaskExecutor

All Implemented Interfaces:

TaskExecutor

public class DefaultDeleteTaskExecutor
extends BasicDeleteTaskExecutor

Executes DeleteTaskInfo directly.

Since:

0.10.0

Constructor Summary

Constructors

Constructor and Description
DefaultDeleteTaskExecutor()

Method Summary

Modifier and Type	Method and Description
protected void	deleteOnHadoopFileSystem(TaskExecutionContext context, String path) Delete files on Hadoop file system.

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

deleteOnLocalFileSystem, execute, isSupported

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultDeleteTaskExecutor

public DefaultDeleteTaskExecutor()

Method Detail

deleteOnHadoopFileSystem

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

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