org.apache.oozie.action.hadoop

Class PigActionExecutor

java.lang.Object

org.apache.oozie.action.ActionExecutor

org.apache.oozie.action.hadoop.JavaActionExecutor

org.apache.oozie.action.hadoop.ScriptLanguageActionExecutor

org.apache.oozie.action.hadoop.PigActionExecutor

public class PigActionExecutor
extends ScriptLanguageActionExecutor

Nested Class Summary

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

ActionExecutor.Context

Field Summary

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

ACL_MODIFY_JOB, ACL_VIEW_JOB, HADOOP_CHILD_JAVA_ENV, HADOOP_CHILD_JAVA_OPTS, HADOOP_JOB_TRACKER, HADOOP_JOB_TRACKER_2, HADOOP_MAP_JAVA_ENV, HADOOP_MAP_JAVA_OPTS, HADOOP_MAP_MEMORY_MB, HADOOP_NAME_NODE, HADOOP_YARN_RM, HADOOP_YARN_UBER_MODE, LOG, MAX_EXTERNAL_STATS_SIZE, MAX_EXTERNAL_STATS_SIZE_DEFAULT, OOZIE_COMMON_LIBDIR, YARN_AM_COMMAND_OPTS, YARN_AM_ENV, YARN_AM_RESOURCE_MB, YARN_MEMORY_MB_MIN

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

CONF_PREFIX, ERROR_OTHER, MAX_RETRIES, requiresNNJT, RETRY_INTERVAL

Constructor Summary

Constructors

Constructor and Description
PigActionExecutor()

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	getCaptureOutput(org.apache.oozie.client.WorkflowAction action)
protected String	getDefaultShareLibName(org.jdom.Element actionXml) Return the sharelib postfix for the action.
List<Class>	getLauncherClasses()
protected String	getLauncherMain(org.apache.hadoop.conf.Configuration launcherConf, org.jdom.Element actionXml)
protected String	getScriptName()
static void	setPigScript(org.apache.hadoop.conf.Configuration conf, String script, String[] params, String[] args)

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

setupLauncherConf

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

addActionLibs, addShareLib, addSystemShareLibForAction, check, createBaseHadoopConf, createJobClient, end, extractHeapSizeMB, getActionCredentialsProperties, getActionData, getCommonLauncherClasses, getCredProperties, getMaxExternalStatsSize, getRunningJob, getShareLibNames, initActionType, isCompleted, kill, parseJobXmlAndConfiguration, prepareActionDir, setActionCompletionData, setCredentialPropertyToActionConf, setCredentialTokens, setLibFilesArchives, 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

Constructor Detail

PigActionExecutor

public PigActionExecutor()

Method Detail

getLauncherClasses

public List<Class> getLauncherClasses()

Overrides:

getLauncherClasses in class ScriptLanguageActionExecutor

getLauncherMain

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

Overrides:

getLauncherMain in class JavaActionExecutor

setPigScript

public static void setPigScript(org.apache.hadoop.conf.Configuration conf,
                String script,
                String[] params,
                String[] args)

getCaptureOutput

protected boolean getCaptureOutput(org.apache.oozie.client.WorkflowAction action)
                            throws org.jdom.JDOMException

Overrides:

getCaptureOutput in class JavaActionExecutor

Throws:

org.jdom.JDOMException

getDefaultShareLibName

protected String getDefaultShareLibName(org.jdom.Element actionXml)

Return the sharelib postfix for the action.

Overrides:

getDefaultShareLibName in class JavaActionExecutor

Parameters:

actionXml -

Returns:

returns pig.

getScriptName

protected String getScriptName()

Specified by:

getScriptName in class ScriptLanguageActionExecutor