org.apache.oozie.action.hadoop
Class ShellActionExecutor

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

public class ShellActionExecutor
extends JavaActionExecutor

Nested Class Summary

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

ActionExecutor.Context

Field Summary

String

OOZIE_LAUNCHER_CHILD_ENV Config property name to set the child environment

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

ACL_MODIFY_JOB, ACL_VIEW_JOB, HADOOP_JOB_TRACKER, HADOOP_JOB_TRACKER_2, HADOOP_NAME_NODE, HADOOP_YARN_RM, log, 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, requiresNNJT, RETRY_INTERVAL

Constructor Summary

ShellActionExecutor()

Method Summary

protected void	addDefaultChildEnv(org.apache.hadoop.conf.Configuration conf) This method sets the PATH to current working directory for the launched map task from where shell command will run.
protected List<Class>	getLauncherClasses()
protected String	getLauncherMain(org.apache.hadoop.conf.Configuration launcherConf, org.jdom.Element actionXml)
protected void	setListInConf(String tag, org.jdom.Element actionXml, org.apache.hadoop.conf.Configuration actionConf, String key, boolean checkKeyValue) This method read a list of tag from an XML element and set the Configuration accordingly
protected org.apache.hadoop.conf.Configuration	setupLauncherConf(org.apache.hadoop.conf.Configuration conf, org.jdom.Element actionXml, org.apache.hadoop.fs.Path appPath, ActionExecutor.Context context)

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

addActionLibs, addShareLib, check, createBaseHadoopConf, createJobClient, end, getActionCredentialsProperties, getActionData, getCaptureOutput, getCredProperties, getDefaultShareLibName, getLauncherJarName, getMaxExternalStatsSize, getShareLibName, initActionType, isCompleted, kill, parseJobXmlAndConfiguration, prepareActionDir, setActionCompletionData, 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_LAUNCHER_CHILD_ENV

public String OOZIE_LAUNCHER_CHILD_ENV

Config property name to set the child environment

Constructor Detail

ShellActionExecutor

public ShellActionExecutor()

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

setListInConf

protected void setListInConf(String tag,
                             org.jdom.Element actionXml,
                             org.apache.hadoop.conf.Configuration actionConf,
                             String key,
                             boolean checkKeyValue)
                      throws ActionExecutorException

This method read a list of tag from an XML element and set the Configuration accordingly

Parameters:

tag -

actionXml -

actionConf -

key -

checkKeyValue -

Throws:

ActionExecutorException

setupLauncherConf

protected org.apache.hadoop.conf.Configuration setupLauncherConf(org.apache.hadoop.conf.Configuration conf,
                                                                 org.jdom.Element actionXml,
                                                                 org.apache.hadoop.fs.Path appPath,
                                                                 ActionExecutor.Context context)
                                                          throws ActionExecutorException

Throws:

ActionExecutorException

addDefaultChildEnv

protected void addDefaultChildEnv(org.apache.hadoop.conf.Configuration conf)

This method sets the PATH to current working directory for the launched map task from where shell command will run.

Parameters:

conf -