com.asakusafw.runtime.stage

Class AbstractCleanupStageClient

java.lang.Object

org.apache.hadoop.conf.Configured

com.asakusafw.runtime.stage.BaseStageClient

com.asakusafw.runtime.stage.AbstractCleanupStageClient

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public abstract class AbstractCleanupStageClient
extends BaseStageClient

Stage client for cleanup phase.

Since:

0.2.6

Version:

0.4.0

Field Summary

Fields

Modifier and Type	Field and Description
static String	IMPLEMENTATION Fully qualified class name of implementation of this class.
static String	METHOD_CLEANUP_PATH The method name of getCleanupPath().

Fields inherited from class com.asakusafw.runtime.stage.BaseStageClient

METHOD_BATCH_ID, METHOD_FLOW_ID, METHOD_STAGE_ID

Constructor Summary

Constructors

Constructor and Description
AbstractCleanupStageClient()

Method Summary

Modifier and Type	Method and Description
protected int	execute(String[] args) Performs stage execution.
protected abstract String	getCleanupPath() Returns the cleanup target path.

Methods inherited from class com.asakusafw.runtime.stage.BaseStageClient

getBatchId, getDefinitionId, getExecutionId, getFlowId, getOperationId, getStageId, getUser, run

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Field Detail

IMPLEMENTATION

public static final String IMPLEMENTATION

Fully qualified class name of implementation of this class.

See Also:

Constant Field Values

METHOD_CLEANUP_PATH

public static final String METHOD_CLEANUP_PATH

The method name of getCleanupPath().

See Also:

Constant Field Values

Constructor Detail

AbstractCleanupStageClient

public AbstractCleanupStageClient()

Method Detail

getCleanupPath

protected abstract String getCleanupPath()

Returns the cleanup target path.

Returns:

the cleanup target path

execute

protected int execute(String[] args)
               throws IOException,
                      InterruptedException

Description copied from class: BaseStageClient

Performs stage execution.

Specified by:

execute in class BaseStageClient

Parameters:

args - arguments

Returns:

exit code of the execution

Throws:

IOException

InterruptedException