org.apache.oozie.action.hadoop
Class HiveActionExecutor

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.HiveActionExecutor

public class HiveActionExecutor
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

HiveActionExecutor()

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 output data of an action.
protected boolean	getCaptureOutput(org.apache.oozie.client.WorkflowAction action)
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 String	getScriptName()
protected void	setActionCompletionData(ActionExecutor.Context context, org.apache.hadoop.fs.FileSystem actionFs) Sets some data for the action on completion
static void	setHiveScript(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

HiveActionExecutor

public HiveActionExecutor()

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

setHiveScript

public static void setHiveScript(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

Description copied from class: JavaActionExecutor

Get the output data of an action. Subclasses should override this method to get action specific output data.

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 actionFs)
                                throws IOException,
                                       HadoopAccessorException,
                                       URISyntaxException

Description copied from class: JavaActionExecutor

Sets some data for the action on completion

Overrides:

setActionCompletionData in class JavaActionExecutor

Parameters:

context - executor context

actionFs - the FileSystem object

Throws:

IOException

HadoopAccessorException

URISyntaxException

getDefaultShareLibName

protected String getDefaultShareLibName(org.jdom.Element actionXml)

Return the sharelib name for the action.

Overrides:

getDefaultShareLibName in class JavaActionExecutor

Parameters:

actionXml -

Returns:

returns hive.

getScriptName

protected String getScriptName()

Specified by:

getScriptName in class ScriptLanguageActionExecutor