public class SqoopActionExecutor extends JavaActionExecutor
ActionExecutor.Context
Modifier and Type | Field and Description |
---|---|
static String |
OOZIE_ACTION_EXTERNAL_STATS_WRITE |
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
CONF_PREFIX, ERROR_OTHER, MAX_RETRIES, requiresNNJT, RETRY_INTERVAL
Constructor and Description |
---|
SqoopActionExecutor() |
Modifier and Type | Method and Description |
---|---|
void |
end(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
We will gather counters from all executed action Hadoop jobs (e.g.
|
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
|
protected boolean |
getCaptureOutput(org.apache.oozie.client.WorkflowAction action) |
protected String |
getDefaultShareLibName(org.jdom.Element actionXml)
Return the sharelib name for the action.
|
List<Class> |
getLauncherClasses() |
protected String |
getLauncherMain(org.apache.hadoop.conf.Configuration launcherConf,
org.jdom.Element actionXml) |
addActionLibs, addShareLib, addSystemShareLibForAction, check, createBaseHadoopConf, createJobClient, extractHeapSizeMB, getActionCredentialsProperties, getCommonLauncherClasses, getCredProperties, getMaxExternalStatsSize, getRunningJob, getShareLibNames, initActionType, isCompleted, kill, parseJobXmlAndConfiguration, prepareActionDir, setActionCompletionData, setCredentialPropertyToActionConf, setCredentialTokens, setLibFilesArchives, 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 SqoopActionExecutor()
public 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
end
in class JavaActionExecutor
context
- Action contextaction
- Workflow actionActionExecutorException
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 boolean getCaptureOutput(org.apache.oozie.client.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
- sqoop
.Copyright © 2014 Apache Software Foundation. All Rights Reserved.