public class MapReduceActionExecutor extends JavaActionExecutor
ActionExecutor.Context
Modifier and Type | Field and Description |
---|---|
static String |
HADOOP_COUNTERS |
static String |
OOZIE_ACTION_EXTERNAL_STATS_WRITE |
static String |
OOZIE_MAPREDUCE_UBER_JAR_ENABLE |
ACL_MODIFY_JOB, ACL_VIEW_JOB, HADOOP_JOB_TRACKER, HADOOP_JOB_TRACKER_2, HADOOP_NAME_NODE, HADOOP_YARN_RM, 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 |
---|
MapReduceActionExecutor() |
Modifier and Type | Method and Description |
---|---|
void |
end(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
End an action after it has executed.
|
protected String |
getDefaultShareLibName(org.jdom.Element actionXml)
Return the sharelib name for the action.
|
protected List<Class> |
getLauncherClasses() |
protected String |
getLauncherMain(org.apache.hadoop.conf.Configuration launcherConf,
org.jdom.Element actionXml) |
protected org.apache.hadoop.mapred.RunningJob |
getRunningJob(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action,
org.apache.hadoop.mapred.JobClient jobClient) |
static void |
setStreaming(org.apache.hadoop.conf.Configuration conf,
String mapper,
String reducer,
String recordReader,
String[] recordReaderMapping,
String[] env) |
addActionLibs, addShareLib, check, createBaseHadoopConf, createJobClient, createLauncherJar, getActionCredentialsProperties, getActionData, getCaptureOutput, getCredProperties, getLauncherJarName, getMaxExternalStatsSize, getShareLibNames, initActionType, isCompleted, kill, parseJobXmlAndConfiguration, prepareActionDir, setActionCompletionData, setCredentialPropertyToActionConf, setCredentialTokens, start, submitLauncher
convertException, disableInit, enableInit, getActionDir, getActionDirPath, getActionSignal, getMaxRetries, getOozieConf, getOozieRuntimeDir, getOozieSystemId, getRetryInterval, getType, registerError, resetInitInfo, setMaxRetries, setRetryInterval
public static final String OOZIE_ACTION_EXTERNAL_STATS_WRITE
public static final String HADOOP_COUNTERS
public static final String OOZIE_MAPREDUCE_UBER_JAR_ENABLE
public MapReduceActionExecutor()
protected List<Class> getLauncherClasses()
getLauncherClasses
in class JavaActionExecutor
protected String getLauncherMain(org.apache.hadoop.conf.Configuration launcherConf, org.jdom.Element actionXml)
getLauncherMain
in class JavaActionExecutor
public void end(ActionExecutor.Context context, org.apache.oozie.client.WorkflowAction action) throws ActionExecutorException
ActionExecutor
ActionExecutor.Context.setEndData(org.apache.oozie.client.WorkflowAction.Status, java.lang.String)
method must be called within this
method.end
in class JavaActionExecutor
context
- executor context.action
- the action to end.ActionExecutorException
- thrown if the action could not end.protected String getDefaultShareLibName(org.jdom.Element actionXml)
getDefaultShareLibName
in class JavaActionExecutor
actionXml
- streaming
if mapreduce-streaming action, NULL
otherwise.public static void setStreaming(org.apache.hadoop.conf.Configuration conf, String mapper, String reducer, String recordReader, String[] recordReaderMapping, String[] env)
protected org.apache.hadoop.mapred.RunningJob getRunningJob(ActionExecutor.Context context, org.apache.oozie.client.WorkflowAction action, org.apache.hadoop.mapred.JobClient jobClient) throws Exception
getRunningJob
in class JavaActionExecutor
Exception
Copyright © 2015 Apache Software Foundation. All Rights Reserved.