org.apache.oozie.action.hadoop
Class PigActionExecutor

java.lang.Object
  extended by org.apache.oozie.action.ActionExecutor
      extended by org.apache.oozie.action.hadoop.JavaActionExecutor
          extended by org.apache.oozie.action.hadoop.ScriptLanguageActionExecutor
              extended by org.apache.oozie.action.hadoop.PigActionExecutor

public class PigActionExecutor
extends ScriptLanguageActionExecutor


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.oozie.action.ActionExecutor
ActionExecutor.Context
 
Field Summary
 
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
 
Fields inherited from class org.apache.oozie.action.ActionExecutor
CONF_PREFIX, ERROR_OTHER, MAX_RETRIES, requiresNNJT, RETRY_INTERVAL
 
Constructor Summary
PigActionExecutor()
           
 
Method Summary
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)
           
 
Methods inherited from class org.apache.oozie.action.hadoop.ScriptLanguageActionExecutor
setupLauncherConf
 
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
 

Constructor Detail

PigActionExecutor

public PigActionExecutor()
Method Detail

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 object
runningJob - the runningJob
action - the Workflow action
context - 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 context
fs - 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.