public class PigActionExecutor extends ScriptLanguageActionExecutor
ActionExecutor.Context, ActionExecutor.RETRYPOLICY
ACL_MODIFY_JOB, ACL_VIEW_JOB, DEFAULT_LAUNCHER_MAX_ATTEMPS, DEFAULT_LAUNCHER_MEMORY_MB, DEFAULT_LAUNCHER_PRIORITY, DEFAULT_LAUNCHER_QUEUE, DEFAULT_LAUNCHER_VCORES, FAILED, FAILED_KILLED, HADOOP_CHILD_JAVA_ENV, HADOOP_CHILD_JAVA_OPTS, HADOOP_JOB_CLASSLOADER, HADOOP_MAP_JAVA_ENV, HADOOP_MAP_JAVA_OPTS, HADOOP_MAP_MEMORY_MB, HADOOP_NAME_NODE, HADOOP_REDUCE_JAVA_OPTS, HADOOP_USER, HADOOP_USER_CLASSPATH_FIRST, HADOOP_YARN_KILL_CHILD_JOBS_ON_AMRESTART, HADOOP_YARN_RM, HADOOP_YARN_TIMELINE_SERVICE_ENABLED, HADOOP_YARN_UBER_MODE, KILLED, LAUNCER_MODIFY_ACL, LAUNCER_VIEW_ACL, LOG, MAPREDUCE_TO_CLASSPATH, MAX_EXTERNAL_STATS_SIZE, OOZIE_ACTION_LAUNCHER_PREFIX, OOZIE_COMMON_LIBDIR, OOZIE_CREDENTIALS_SKIP, OOZIE_LAUNCHER_ADD_MAPREDUCE_TO_CLASSPATH_PROPERTY, RUNNING, SUCCEEDED, workflowConf, YARN_AM_COMMAND_OPTS, YARN_AM_ENV, YARN_AM_RESOURCE_MB, YARN_MEMORY_MB_MIN
ACTION_RETRY_INTERVAL, ACTION_RETRY_POLICY, CONF_PREFIX, ERROR_OTHER, MAX_RETRIES, OOZIE_ACTION_YARN_TAG, RETRY_INTERVAL
Constructor and Description |
---|
PigActionExecutor() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
getCaptureOutput(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() |
protected org.apache.hadoop.conf.Configuration |
loadHadoopDefaultResources(ActionExecutor.Context context,
org.jdom.Element actionXml) |
static void |
setPigScript(org.apache.hadoop.conf.Configuration conf,
String script,
String[] params,
String[] args) |
addScriptToCache, setupLauncherConf, shouldAddScriptToCache
addActionLibs, addActionSpecificEnvVars, addAppNameContext, addShareLib, addSystemShareLibForAction, check, createBaseHadoopConf, createBaseHadoopConf, createJobClient, createYarnClient, end, getActionCredentialsProperties, getActionData, getActualExternalId, getAppName, getCommonLauncherClasses, getCredProperties, getMaxExternalStatsSize, getMaxOutputData, getShareLibFilesForActionConf, getShareLibNames, getTrimmedEncodedPath, initActionType, injectCallback, isCompleted, kill, parseJobXmlAndConfiguration, parseJobXmlAndConfiguration, prepareActionDir, requiresNameNodeJobTracker, setActionCompletionData, setActionTokenProperties, setCredentialTokens, setLibFilesArchives, start, submitLauncher, supportsConfigurationJobXML
convertException, disableInit, enableInit, getActionDir, getActionDirPath, getActionSignal, getActionYarnTag, getMaxRetries, getOozieConf, getOozieRuntimeDir, getOozieSystemId, getRetryInterval, getRetryPolicy, getType, registerError, resetInitInfo, setMaxRetries, setRetryInterval, setRetryPolicy
public PigActionExecutor()
public List<Class<?>> getLauncherClasses()
getLauncherClasses
in class ScriptLanguageActionExecutor
protected String getLauncherMain(org.apache.hadoop.conf.Configuration launcherConf, org.jdom.Element actionXml)
getLauncherMain
in class JavaActionExecutor
public static void setPigScript(org.apache.hadoop.conf.Configuration conf, String script, String[] params, String[] args)
protected boolean getCaptureOutput(WorkflowAction action) throws org.jdom.JDOMException
getCaptureOutput
in class JavaActionExecutor
org.jdom.JDOMException
protected String getDefaultShareLibName(org.jdom.Element actionXml)
getDefaultShareLibName
in class JavaActionExecutor
actionXml
- pig
.protected String getScriptName()
getScriptName
in class ScriptLanguageActionExecutor
protected org.apache.hadoop.conf.Configuration loadHadoopDefaultResources(ActionExecutor.Context context, org.jdom.Element actionXml)
loadHadoopDefaultResources
in class JavaActionExecutor
Copyright © 2018 Apache Software Foundation. All rights reserved.