Modifier and Type | Method and Description |
---|---|
protected ActionExecutorException |
ActionExecutor.convertException(Exception ex)
Utility method to handle exceptions in the
ActionExecutor.start(org.apache.oozie.action.ActionExecutor.Context, org.apache.oozie.client.WorkflowAction) , ActionExecutor.end(org.apache.oozie.action.ActionExecutor.Context, org.apache.oozie.client.WorkflowAction) , ActionExecutor.kill(org.apache.oozie.action.ActionExecutor.Context, org.apache.oozie.client.WorkflowAction) and ActionExecutor.check(org.apache.oozie.action.ActionExecutor.Context, org.apache.oozie.client.WorkflowAction) methods |
Modifier and Type | Method and Description |
---|---|
abstract void |
ActionExecutor.check(ActionExecutor.Context context,
WorkflowAction action)
Check if an action has completed.
|
abstract void |
ActionExecutor.end(ActionExecutor.Context context,
WorkflowAction action)
End an action after it has executed.
|
abstract void |
ActionExecutor.kill(ActionExecutor.Context context,
WorkflowAction action)
Kill an action.
|
abstract void |
ActionExecutor.start(ActionExecutor.Context context,
WorkflowAction action)
Start an action.
|
Modifier and Type | Method and Description |
---|---|
void |
ControlNodeActionExecutor.check(ActionExecutor.Context context,
WorkflowAction action) |
void |
ControlNodeActionExecutor.end(ActionExecutor.Context context,
WorkflowAction action) |
void |
ControlNodeActionExecutor.kill(ActionExecutor.Context context,
WorkflowAction action) |
void |
ControlNodeActionExecutor.start(ActionExecutor.Context context,
WorkflowAction action) |
Modifier and Type | Method and Description |
---|---|
void |
DecisionActionExecutor.check(ActionExecutor.Context context,
WorkflowAction action) |
void |
DecisionActionExecutor.end(ActionExecutor.Context context,
WorkflowAction action) |
void |
DecisionActionExecutor.kill(ActionExecutor.Context context,
WorkflowAction action) |
void |
DecisionActionExecutor.start(ActionExecutor.Context context,
WorkflowAction action) |
Modifier and Type | Method and Description |
---|---|
void |
EmailActionExecutor.check(ActionExecutor.Context context,
WorkflowAction action) |
void |
EmailActionExecutor.email(String[] to,
String[] cc,
String[] bcc,
String subject,
String body,
String[] attachments,
String contentType,
String user) |
void |
EmailActionExecutor.email(String[] to,
String[] cc,
String subject,
String body,
String[] attachments,
String contentType,
String user) |
void |
EmailActionExecutor.end(ActionExecutor.Context context,
WorkflowAction action) |
void |
EmailActionExecutor.kill(ActionExecutor.Context context,
WorkflowAction action) |
void |
EmailActionExecutor.start(ActionExecutor.Context context,
WorkflowAction action) |
protected void |
EmailActionExecutor.validateAndMail(ActionExecutor.Context context,
org.jdom.Element element) |
Modifier and Type | Method and Description |
---|---|
protected void |
JavaActionExecutor.addActionLibs(org.apache.hadoop.fs.Path appPath,
org.apache.hadoop.conf.Configuration conf) |
protected void |
ScriptLanguageActionExecutor.addScriptToCache(org.apache.hadoop.conf.Configuration conf,
org.jdom.Element actionXml,
org.apache.hadoop.fs.Path appPath,
ActionExecutor.Context context) |
protected void |
JavaActionExecutor.addShareLib(org.apache.hadoop.conf.Configuration conf,
String[] actionShareLibNames) |
protected void |
JavaActionExecutor.addSystemShareLibForAction(org.apache.hadoop.conf.Configuration conf) |
void |
JavaActionExecutor.check(ActionExecutor.Context context,
WorkflowAction action) |
void |
FsActionExecutor.check(ActionExecutor.Context context,
WorkflowAction action) |
void |
FsActionExecutor.delete(ActionExecutor.Context context,
org.apache.hadoop.fs.Path path)
Delete path
|
void |
FsActionExecutor.delete(ActionExecutor.Context context,
XConfiguration fsConf,
org.apache.hadoop.fs.Path nameNodePath,
org.apache.hadoop.fs.Path path,
boolean skipTrash)
Delete path
|
void |
FsActionExecutor.delete(String user,
String group,
org.apache.hadoop.fs.Path path)
Delete path
|
void |
SqoopActionExecutor.end(ActionExecutor.Context context,
WorkflowAction action)
We will gather counters from all executed action Hadoop jobs (e.g.
|
void |
MapReduceActionExecutor.end(ActionExecutor.Context context,
WorkflowAction action) |
void |
JavaActionExecutor.end(ActionExecutor.Context context,
WorkflowAction action) |
void |
FsActionExecutor.end(ActionExecutor.Context context,
WorkflowAction action) |
void |
JavaActionExecutor.kill(ActionExecutor.Context context,
WorkflowAction action) |
void |
FsActionExecutor.kill(ActionExecutor.Context context,
WorkflowAction action) |
void |
FsActionExecutor.move(ActionExecutor.Context context,
org.apache.hadoop.fs.Path source,
org.apache.hadoop.fs.Path target,
boolean recovery)
Move source to target
|
void |
FsActionExecutor.move(ActionExecutor.Context context,
XConfiguration fsConf,
org.apache.hadoop.fs.Path nameNodePath,
org.apache.hadoop.fs.Path source,
org.apache.hadoop.fs.Path target,
boolean recovery)
Move source to target
|
static void |
JavaActionExecutor.parseJobXmlAndConfiguration(ActionExecutor.Context context,
org.jdom.Element element,
org.apache.hadoop.fs.Path appPath,
org.apache.hadoop.conf.Configuration conf) |
static void |
JavaActionExecutor.parseJobXmlAndConfiguration(ActionExecutor.Context context,
org.jdom.Element element,
org.apache.hadoop.fs.Path appPath,
org.apache.hadoop.conf.Configuration conf,
boolean isLauncher) |
void |
JavaActionExecutor.prepareActionDir(org.apache.hadoop.fs.FileSystem actionFs,
ActionExecutor.Context context) |
void |
JavaActionExecutor.setLibFilesArchives(ActionExecutor.Context context,
org.jdom.Element actionXml,
org.apache.hadoop.fs.Path appPath,
org.apache.hadoop.conf.Configuration conf) |
protected void |
ShellActionExecutor.setListInConf(String tag,
org.jdom.Element actionXml,
org.apache.hadoop.conf.Configuration actionConf,
String key,
boolean checkKeyValue)
This method read a list of tag from an XML element and set the
Configuration accordingly
|
protected org.apache.hadoop.conf.Configuration |
ShellActionExecutor.setupLauncherConf(org.apache.hadoop.conf.Configuration conf,
org.jdom.Element actionXml,
org.apache.hadoop.fs.Path appPath,
ActionExecutor.Context context) |
protected org.apache.hadoop.conf.Configuration |
ScriptLanguageActionExecutor.setupLauncherConf(org.apache.hadoop.conf.Configuration conf,
org.jdom.Element actionXml,
org.apache.hadoop.fs.Path appPath,
ActionExecutor.Context context) |
void |
JavaActionExecutor.start(ActionExecutor.Context context,
WorkflowAction action) |
void |
FsActionExecutor.start(ActionExecutor.Context context,
WorkflowAction action) |
void |
JavaActionExecutor.submitLauncher(org.apache.hadoop.fs.FileSystem actionFs,
ActionExecutor.Context context,
WorkflowAction action) |
Modifier and Type | Method and Description |
---|---|
void |
SubWorkflowActionExecutor.check(ActionExecutor.Context context,
WorkflowAction action) |
void |
SubWorkflowActionExecutor.end(ActionExecutor.Context context,
WorkflowAction action) |
protected void |
SubWorkflowActionExecutor.injectInline(org.jdom.Element eConf,
org.apache.hadoop.conf.Configuration subWorkflowConf) |
void |
SubWorkflowActionExecutor.kill(ActionExecutor.Context context,
WorkflowAction action) |
void |
SubWorkflowActionExecutor.start(ActionExecutor.Context context,
WorkflowAction action) |
protected void |
SubWorkflowActionExecutor.verifyAndInjectSubworkflowDepth(org.apache.hadoop.conf.Configuration parentConf,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
SshActionExecutor.check(ActionExecutor.Context context,
WorkflowAction action)
Check ssh action status.
|
void |
SshActionExecutor.end(ActionExecutor.Context context,
WorkflowAction action)
End action execution.
|
protected WorkflowAction.Status |
SshActionExecutor.getActionStatus(ActionExecutor.Context context,
WorkflowAction action)
Get action status.
|
void |
SshActionExecutor.kill(ActionExecutor.Context context,
WorkflowAction action)
Kill ssh action.
|
void |
SshActionExecutor.start(ActionExecutor.Context context,
WorkflowAction action)
Start the ssh action execution.
|
Copyright © 2016 Apache Software Foundation. All rights reserved.