org.apache.oozie.action.hadoop
Class MapReduceActionExecutor

java.lang.Object
  org.apache.oozie.action.ActionExecutor
      org.apache.oozie.action.hadoop.JavaActionExecutor
          org.apache.oozie.action.hadoop.MapReduceActionExecutor

public class MapReduceActionExecutor
extends JavaActionExecutor

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.oozie.action.ActionExecutor

ActionExecutor.Context

Field Summary

static String	HADOOP_COUNTERS
static String	OOZIE_ACTION_EXTERNAL_STATS_WRITE

Fields inherited from class org.apache.oozie.action.hadoop.JavaActionExecutor

MAX_EXTERNAL_STATS_SIZE, MAX_EXTERNAL_STATS_SIZE_DEFAULT, OOZIE_COMMON_LIBDIR

Fields inherited from class org.apache.oozie.action.ActionExecutor

CONF_PREFIX, ERROR_OTHER, MAX_RETRIES, RETRY_INTERVAL

Constructor Summary

MapReduceActionExecutor()

Method Summary

void	end(ActionExecutor.Context context, org.apache.oozie.client.WorkflowAction action) End an action after it has executed.
protected List<Class>	getLauncherClasses()
protected String	getLauncherMain(org.apache.hadoop.conf.Configuration launcherConf, org.jdom.Element actionXml)
protected String	getShareLibPostFix(ActionExecutor.Context context, org.jdom.Element actionXml) Return the sharelib postfix for the action.

Methods inherited from class org.apache.oozie.action.hadoop.JavaActionExecutor

addShareLib, check, createBaseHadoopConf, createJobClient, getActionCredentialsProperties, getActionData, getActionFileSystem, getActionFileSystem, getCaptureOutput, getCredProperties, getLauncherJarName, getMaxExternalStatsSize, initActionType, isCompleted, kill, prepareActionDir, setCredentialPropertyToActionConf, setCredentialTokens, start, submitLauncher

Methods inherited from class org.apache.oozie.action.ActionExecutor

convertException, disableInit, enableInit, getActionDir, getActionDirPath, getActionSignal, getMaxRetries, getOozieConf, getOozieRuntimeDir, getOozieSystemId, getRetryInterval, getType, registerError, resetInitInfo, setMaxRetries, setRetryInterval

Methods inherited from class java.lang.Object

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

Field Detail

OOZIE_ACTION_EXTERNAL_STATS_WRITE

public static final String OOZIE_ACTION_EXTERNAL_STATS_WRITE

See Also:

Constant Field Values

HADOOP_COUNTERS

public static final String HADOOP_COUNTERS

See Also:

Constant Field Values

Constructor Detail

MapReduceActionExecutor

public MapReduceActionExecutor()

Method Detail

getLauncherClasses

protected List<Class> getLauncherClasses()

Overrides:

getLauncherClasses in class JavaActionExecutor

getLauncherMain

protected String getLauncherMain(org.apache.hadoop.conf.Configuration launcherConf,
                                 org.jdom.Element actionXml)

Overrides:

getLauncherMain in class JavaActionExecutor

end

public void end(ActionExecutor.Context context,
                org.apache.oozie.client.WorkflowAction action)
         throws ActionExecutorException

Description copied from class: ActionExecutor

End an action after it has executed.

The ActionExecutor.Context.setEndData(org.apache.oozie.client.WorkflowAction.Status, java.lang.String) method must be called within this method.

Overrides:

end in class JavaActionExecutor

Parameters:

context - executor context.

action - the action to end.

Throws:

ActionExecutorException - thrown if the action could not end.

getShareLibPostFix

protected String getShareLibPostFix(ActionExecutor.Context context,
                                    org.jdom.Element actionXml)

Return the sharelib postfix for the action.

Overrides:

getShareLibPostFix in class JavaActionExecutor

Parameters:

context - executor context.

actionXml - the action XML.

Returns:

the action sharelib post fix, this implementation returns NULL or streaming if the mapreduce action is streaming.