This project has retired. For details please refer to its
Attic page .
PigActionExecutor (Apache Oozie Core 4.0.0 API)
org.apache.oozie.action.hadoop
Class PigActionExecutor
java.lang.Object
org.apache.oozie.action.ActionExecutor
org.apache.oozie.action.hadoop.JavaActionExecutor
org.apache.oozie.action.hadoop.ScriptLanguageActionExecutor
org.apache.oozie.action.hadoop.PigActionExecutor
public class PigActionExecutor extends ScriptLanguageActionExecutor
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 , end , getActionCredentialsProperties , getCredProperties , getLauncherJarName , getMaxExternalStatsSize , getRunningJob , getShareLibNames , initActionType , isCompleted , kill , parseJobXmlAndConfiguration , prepareActionDir , 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
PigActionExecutor
public PigActionExecutor ()
getLauncherClasses
protected List <Class > getLauncherClasses ()
Overrides: getLauncherClasses
in class ScriptLanguageActionExecutor
getLauncherMain
protected String getLauncherMain (org.apache.hadoop.conf.Configuration launcherConf,
org.jdom.Element actionXml)
Overrides: getLauncherMain
in class JavaActionExecutor
setPigScript
public static void setPigScript (org.apache.hadoop.conf.Configuration conf,
String script,
String [] params,
String [] args)
getCaptureOutput
protected boolean getCaptureOutput (org.apache.oozie.client.WorkflowAction action)
throws org.jdom.JDOMException
Overrides: getCaptureOutput
in class JavaActionExecutor
Throws:
org.jdom.JDOMException
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 for a pig job
Overrides: getActionData
in class JavaActionExecutor
Parameters: actionFs
- the FileSystem objectrunningJob
- the runningJobaction
- the Workflow actioncontext
- executor context
Throws:
HadoopAccessorException
org.jdom.JDOMException
IOException
URISyntaxException
setActionCompletionData
protected void setActionCompletionData (ActionExecutor.Context context,
org.apache.hadoop.fs.FileSystem fs)
throws HadoopAccessorException ,
IOException ,
URISyntaxException
Description copied from class: JavaActionExecutor
Sets some data for the action on completion
Overrides: setActionCompletionData
in class JavaActionExecutor
Parameters: context
- executor contextfs
- the FileSystem object
Throws:
HadoopAccessorException
IOException
URISyntaxException
getDefaultShareLibName
protected String getDefaultShareLibName (org.jdom.Element actionXml)
Return the sharelib postfix for the action.
Overrides: getDefaultShareLibName
in class JavaActionExecutor
Parameters: actionXml
-
Returns: returns pig
.
getScriptName
protected String getScriptName ()
Specified by: getScriptName
in class ScriptLanguageActionExecutor
Copyright © 2013 Apache Software Foundation . All Rights Reserved.