public class HiveActionExecutor extends ScriptLanguageActionExecutor
ActionExecutor.Context
ACL_MODIFY_JOB, ACL_VIEW_JOB, HADOOP_CHILD_JAVA_ENV, HADOOP_CHILD_JAVA_OPTS, HADOOP_JOB_TRACKER, HADOOP_JOB_TRACKER_2, HADOOP_MAP_JAVA_ENV, HADOOP_MAP_JAVA_OPTS, HADOOP_MAP_MEMORY_MB, HADOOP_NAME_NODE, HADOOP_YARN_RM, HADOOP_YARN_UBER_MODE, LOG, MAX_EXTERNAL_STATS_SIZE, MAX_EXTERNAL_STATS_SIZE_DEFAULT, OOZIE_COMMON_LIBDIR, YARN_AM_COMMAND_OPTS, YARN_AM_ENV, YARN_AM_RESOURCE_MB, YARN_MEMORY_MB_MIN
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.
|
List<Class> |
getLauncherClasses() |
protected String |
getLauncherMain(org.apache.hadoop.conf.Configuration launcherConf,
org.jdom.Element actionXml) |
protected String |
getScriptName() |
static void |
setHiveScript(org.apache.hadoop.conf.Configuration conf,
String script,
String[] params,
String[] args) |
setupLauncherConf
addActionLibs, addShareLib, addSystemShareLibForAction, check, createBaseHadoopConf, createJobClient, end, extractHeapSizeMB, getActionCredentialsProperties, getCommonLauncherClasses, getCredProperties, getMaxExternalStatsSize, getRunningJob, getShareLibNames, initActionType, isCompleted, kill, parseJobXmlAndConfiguration, prepareActionDir, setActionCompletionData, setCredentialPropertyToActionConf, setCredentialTokens, setLibFilesArchives, start, submitLauncher
convertException, disableInit, enableInit, getActionDir, getActionDirPath, getActionSignal, getMaxRetries, getOozieConf, getOozieRuntimeDir, getOozieSystemId, getRetryInterval, getType, registerError, resetInitInfo, setMaxRetries, setRetryInterval
public HiveActionExecutor()
public 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 String getDefaultShareLibName(org.jdom.Element actionXml)
getDefaultShareLibName
in class JavaActionExecutor
actionXml
- hive
.protected String getScriptName()
getScriptName
in class ScriptLanguageActionExecutor
Copyright © 2014 Apache Software Foundation. All Rights Reserved.