public class PigActionExecutor extends ScriptLanguageActionExecutor
ActionExecutor.Context
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_ACTION_SHIP_LAUNCHER_JAR, OOZIE_COMMON_LIBDIR
CONF_PREFIX, ERROR_OTHER, MAX_RETRIES, requiresNNJT, RETRY_INTERVAL
Constructor and Description |
---|
PigActionExecutor() |
Modifier and Type | Method and Description |
---|---|
protected void |
getActionData(org.apache.hadoop.fs.FileSystem actionFs,
org.apache.hadoop.mapred.RunningJob runningJob,
org.apache.oozie.client.WorkflowAction action,
ActionExecutor.Context context)
Get the stats and external child IDs for a pig job
|
protected boolean |
getCaptureOutput(org.apache.oozie.client.WorkflowAction action) |
protected String |
getDefaultShareLibName(org.jdom.Element actionXml)
Return the sharelib postfix for the action.
|
protected List<Class> |
getLauncherClasses() |
protected String |
getLauncherMain(org.apache.hadoop.conf.Configuration launcherConf,
org.jdom.Element actionXml) |
protected String |
getScriptName() |
protected void |
setActionCompletionData(ActionExecutor.Context context,
org.apache.hadoop.fs.FileSystem fs)
Sets some data for the action on completion
|
static void |
setPigScript(org.apache.hadoop.conf.Configuration conf,
String script,
String[] params,
String[] args) |
setupLauncherConf
addActionLibs, addShareLib, check, createBaseHadoopConf, createJobClient, createLauncherJar, end, getActionCredentialsProperties, getCredProperties, getLauncherJarName, getMaxExternalStatsSize, getRunningJob, getShareLibNames, initActionType, isCompleted, kill, parseJobXmlAndConfiguration, prepareActionDir, setCredentialPropertyToActionConf, setCredentialTokens, start, submitLauncher
convertException, disableInit, enableInit, getActionDir, getActionDirPath, getActionSignal, getMaxRetries, getOozieConf, getOozieRuntimeDir, getOozieSystemId, getRetryInterval, getType, registerError, resetInitInfo, setMaxRetries, setRetryInterval
public PigActionExecutor()
protected 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(org.apache.oozie.client.WorkflowAction action) throws org.jdom.JDOMException
getCaptureOutput
in class JavaActionExecutor
org.jdom.JDOMException
protected void getActionData(org.apache.hadoop.fs.FileSystem actionFs, org.apache.hadoop.mapred.RunningJob runningJob, org.apache.oozie.client.WorkflowAction action, ActionExecutor.Context context) throws HadoopAccessorException, org.jdom.JDOMException, IOException, URISyntaxException
getActionData
in class JavaActionExecutor
actionFs
- the FileSystem objectrunningJob
- the runningJobaction
- the Workflow actioncontext
- executor contextHadoopAccessorException
org.jdom.JDOMException
IOException
URISyntaxException
protected void setActionCompletionData(ActionExecutor.Context context, org.apache.hadoop.fs.FileSystem fs) throws HadoopAccessorException, IOException, URISyntaxException
JavaActionExecutor
setActionCompletionData
in class JavaActionExecutor
context
- executor contextfs
- the FileSystem objectHadoopAccessorException
IOException
URISyntaxException
protected String getDefaultShareLibName(org.jdom.Element actionXml)
getDefaultShareLibName
in class JavaActionExecutor
actionXml
- pig
.protected String getScriptName()
getScriptName
in class ScriptLanguageActionExecutor
Copyright © 2015 Apache Software Foundation. All Rights Reserved.