public class HiveActionExecutor extends ScriptLanguageActionExecutor
ActionExecutor.Context
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
CONF_PREFIX, ERROR_OTHER, MAX_RETRIES, requiresNNJT, RETRY_INTERVAL
Constructor and Description |
---|
HiveActionExecutor() |
Modifier and Type | Method and Description |
---|---|
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) |
setupLauncherConf
addActionLibs, addShareLib, check, createBaseHadoopConf, createJobClient, createLauncherJar, end, getActionCredentialsProperties, getCredProperties, getLauncherJarName, getMaxExternalStatsSize, getRunningJob, getShareLibNames, initActionType, isCompleted, kill, parseJobXmlAndConfiguration, prepareActionDir, setCredentialPropertyToActionConf, setCredentialTokens, start, submitLauncher
convertException, disableInit, enableInit, getActionDir, getActionDirPath, getActionSignal, getMaxRetries, getOozieConf, getOozieRuntimeDir, getOozieSystemId, getRetryInterval, getType, registerError, resetInitInfo, setMaxRetries, setRetryInterval
public HiveActionExecutor()
protected List<Class> getLauncherClasses()
getLauncherClasses
in class ScriptLanguageActionExecutor
protected String getLauncherMain(org.apache.hadoop.conf.Configuration launcherConf, org.jdom.Element actionXml)
getLauncherMain
in class JavaActionExecutor
public static void setHiveScript(org.apache.hadoop.conf.Configuration conf, String script, String[] params, String[] args)
protected boolean getCaptureOutput(org.apache.oozie.client.WorkflowAction action) throws org.jdom.JDOMException
getCaptureOutput
in class JavaActionExecutor
org.jdom.JDOMException
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
JavaActionExecutor
getActionData
in class JavaActionExecutor
actionFs
- the FileSystem objectrunningJob
- the runningJobaction
- the Workflow actioncontext
- executor contextHadoopAccessorException
org.jdom.JDOMException
IOException
URISyntaxException
protected void setActionCompletionData(ActionExecutor.Context context, org.apache.hadoop.fs.FileSystem actionFs) throws IOException, HadoopAccessorException, URISyntaxException
JavaActionExecutor
setActionCompletionData
in class JavaActionExecutor
context
- executor contextactionFs
- the FileSystem objectIOException
HadoopAccessorException
URISyntaxException
protected String getDefaultShareLibName(org.jdom.Element actionXml)
getDefaultShareLibName
in class JavaActionExecutor
actionXml
- hive
.protected String getScriptName()
getScriptName
in class ScriptLanguageActionExecutor
Copyright © 2015 Apache Software Foundation. All Rights Reserved.