This project has retired. For details please refer to its
Attic page .
SqoopActionExecutor (Apache Oozie Core 4.0.0 API)
org.apache.oozie.action.hadoop
Class SqoopActionExecutor
java.lang.Object
org.apache.oozie.action.ActionExecutor
org.apache.oozie.action.hadoop.JavaActionExecutor
org.apache.oozie.action.hadoop.SqoopActionExecutor
public class SqoopActionExecutor extends JavaActionExecutor
Fields inherited from class org.apache.oozie.action.hadoop.JavaActionExecutor
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
Methods inherited from class org.apache.oozie.action.hadoop.JavaActionExecutor
addActionLibs , addShareLib , check , createBaseHadoopConf , createJobClient , createLauncherJar , getActionCredentialsProperties , getCredProperties , getLauncherJarName , getMaxExternalStatsSize , getRunningJob , getShareLibNames , initActionType , isCompleted , kill , parseJobXmlAndConfiguration , prepareActionDir , setActionCompletionData , setCredentialPropertyToActionConf , setCredentialTokens , 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
OOZIE_ACTION_EXTERNAL_STATS_WRITE
public static final String OOZIE_ACTION_EXTERNAL_STATS_WRITE
See Also: Constant Field Values
SqoopActionExecutor
public SqoopActionExecutor ()
getLauncherClasses
protected List <Class > getLauncherClasses ()
Overrides: getLauncherClasses
in class JavaActionExecutor
getLauncherMain
protected String getLauncherMain (org.apache.hadoop.conf.Configuration launcherConf,
org.jdom.Element actionXml)
Overrides: getLauncherMain
in class JavaActionExecutor
end
public void end (ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
throws ActionExecutorException
We will gather counters from all executed action Hadoop jobs (e.g. jobs
that moved data, not the launcher itself) and merge them together. There
will be only one job most of the time. The only exception is
import-all-table option that will execute one job per one exported table.
Overrides: end
in class JavaActionExecutor
Parameters: context
- Action contextaction
- Workflow action
Throws:
ActionExecutorException
getActionData
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
Get the stats and external child IDs
Overrides: getActionData
in class JavaActionExecutor
Parameters: actionFs
- the FileSystem objectrunningJob
- the runningJobaction
- the Workflow actioncontext
- executor context
Throws:
HadoopAccessorException
org.jdom.JDOMException
IOException
URISyntaxException
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 name for the action.
Overrides: getDefaultShareLibName
in class JavaActionExecutor
Parameters: actionXml
-
Returns: returns sqoop
.
Copyright © 2013 Apache Software Foundation . All Rights Reserved.