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.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 |
ScriptLanguageActionExecutor.addScriptToCache(org.apache.hadoop.conf.Configuration conf,
org.jdom.Element actionXml,
org.apache.hadoop.fs.Path appPath,
ActionExecutor.Context context) |
void |
Hive2Credentials.addtoJobConf(org.apache.hadoop.mapred.JobConf jobconf,
CredentialsProperties props,
ActionExecutor.Context context) |
void |
HCatCredentials.addtoJobConf(org.apache.hadoop.mapred.JobConf jobconf,
CredentialsProperties props,
ActionExecutor.Context context) |
void |
HbaseCredentials.addtoJobConf(org.apache.hadoop.mapred.JobConf jobConf,
CredentialsProperties props,
ActionExecutor.Context context) |
abstract void |
Credentials.addtoJobConf(org.apache.hadoop.mapred.JobConf jobconf,
CredentialsProperties props,
ActionExecutor.Context context)
This is the interface for all the Credentials implementation.
|
void |
JavaActionExecutor.check(ActionExecutor.Context context,
WorkflowAction action) |
void |
FsActionExecutor.check(ActionExecutor.Context context,
WorkflowAction action) |
org.apache.hadoop.mapred.JobConf |
JavaActionExecutor.createBaseHadoopConf(ActionExecutor.Context context,
org.jdom.Element actionXml) |
protected org.apache.hadoop.mapred.JobConf |
JavaActionExecutor.createBaseHadoopConf(ActionExecutor.Context context,
org.jdom.Element actionXml,
boolean loadResources) |
protected org.apache.hadoop.mapred.JobClient |
JavaActionExecutor.createJobClient(ActionExecutor.Context context,
org.apache.hadoop.mapred.JobConf jobConf)
Create job client object
|
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 |
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) |
protected HashMap<String,CredentialsProperties> |
JavaActionExecutor.getActionCredentialsProperties(ActionExecutor.Context context,
WorkflowAction action) |
protected void |
JavaActionExecutor.getActionData(org.apache.hadoop.fs.FileSystem actionFs,
org.apache.hadoop.mapred.RunningJob runningJob,
WorkflowAction action,
ActionExecutor.Context context)
Get the output data of an action.
|
protected CredentialsProperties |
JavaActionExecutor.getCredProperties(ActionExecutor.Context context,
String credName) |
org.apache.hadoop.fs.Path |
FsActionExecutor.getRecoveryPath(ActionExecutor.Context context) |
protected org.apache.hadoop.mapred.RunningJob |
MapReduceActionExecutor.getRunningJob(ActionExecutor.Context context,
WorkflowAction action,
org.apache.hadoop.mapred.JobClient jobClient) |
protected org.apache.hadoop.mapred.RunningJob |
JavaActionExecutor.getRunningJob(ActionExecutor.Context context,
WorkflowAction action,
org.apache.hadoop.mapred.JobClient jobClient) |
protected String[] |
JavaActionExecutor.getShareLibNames(ActionExecutor.Context context,
org.jdom.Element actionXml,
org.apache.hadoop.conf.Configuration conf)
Return the sharelib names for the action.
|
protected void |
JavaActionExecutor.injectCallback(ActionExecutor.Context context,
org.apache.hadoop.conf.Configuration conf) |
void |
JavaActionExecutor.kill(ActionExecutor.Context context,
WorkflowAction action) |
void |
FsActionExecutor.kill(ActionExecutor.Context context,
WorkflowAction action) |
protected org.apache.hadoop.mapred.JobConf |
PigActionExecutor.loadHadoopDefaultResources(ActionExecutor.Context context,
org.jdom.Element actionXml) |
protected org.apache.hadoop.mapred.JobConf |
JavaActionExecutor.loadHadoopDefaultResources(ActionExecutor.Context context,
org.jdom.Element actionXml) |
protected org.apache.hadoop.mapred.JobConf |
HiveActionExecutor.loadHadoopDefaultResources(ActionExecutor.Context context,
org.jdom.Element actionXml) |
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) |
protected void |
JavaActionExecutor.setActionCompletionData(ActionExecutor.Context context,
org.apache.hadoop.fs.FileSystem actionFs)
Sets some data for the action on completion
|
protected HashMap<String,CredentialsProperties> |
JavaActionExecutor.setCredentialPropertyToActionConf(ActionExecutor.Context context,
WorkflowAction action,
org.apache.hadoop.conf.Configuration actionConf) |
protected void |
JavaActionExecutor.setCredentialTokens(org.apache.hadoop.mapred.JobConf jobconf,
ActionExecutor.Context context,
WorkflowAction action,
HashMap<String,CredentialsProperties> credPropertiesMap) |
void |
JavaActionExecutor.setLibFilesArchives(ActionExecutor.Context context,
org.jdom.Element actionXml,
org.apache.hadoop.fs.Path appPath,
org.apache.hadoop.conf.Configuration conf) |
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) |
Constructor and Description |
---|
OozieJobInfo(org.apache.hadoop.conf.Configuration actionConf,
ActionExecutor.Context context,
WorkflowAction action)
Instantiates a new oozie job info.
|
Modifier and Type | Method and Description |
---|---|
void |
SubWorkflowActionExecutor.check(ActionExecutor.Context context,
WorkflowAction action) |
void |
SubWorkflowActionExecutor.end(ActionExecutor.Context context,
WorkflowAction action) |
protected OozieClient |
SubWorkflowActionExecutor.getWorkflowClient(ActionExecutor.Context context,
String oozieUri) |
protected void |
SubWorkflowActionExecutor.injectCallback(ActionExecutor.Context context,
org.apache.hadoop.conf.Configuration conf) |
void |
SubWorkflowActionExecutor.kill(ActionExecutor.Context context,
WorkflowAction action) |
void |
SubWorkflowActionExecutor.start(ActionExecutor.Context context,
WorkflowAction action) |
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.
|
String |
SshActionExecutor.getRemoteFileName(ActionExecutor.Context context,
WorkflowAction action,
String fileExtension,
boolean dirOnly,
boolean useExtId)
Get remote host working location.
|
void |
SshActionExecutor.kill(ActionExecutor.Context context,
WorkflowAction action)
Kill ssh action.
|
protected String |
SshActionExecutor.setupRemote(String host,
ActionExecutor.Context context,
WorkflowAction action)
Do ssh action execution setup on remote host.
|
void |
SshActionExecutor.start(ActionExecutor.Context context,
WorkflowAction action)
Start the ssh action execution.
|
Modifier and Type | Class and Description |
---|---|
static class |
ActionXCommand.ActionExecutorContext
Workflow action executor context
|
static class |
ActionXCommand.ForkedActionExecutorContext |
Modifier and Type | Method and Description |
---|---|
void |
ActionXCommand.failJob(ActionExecutor.Context context)
Fail the job due to failed action
|
void |
ForkedActionStartXCommand.failJob(ActionExecutor.Context context,
WorkflowActionBean action) |
void |
ActionXCommand.failJob(ActionExecutor.Context context,
WorkflowActionBean action)
Fail the job due to failed action
|
protected void |
ActionXCommand.handleError(ActionExecutor.Context context,
ActionExecutor executor,
String message,
boolean isStart,
WorkflowAction.Status status)
Takes care of errors.
|
protected void |
ForkedActionStartXCommand.handleNonTransient(ActionExecutor.Context context,
ActionExecutor executor,
WorkflowAction.Status status) |
protected void |
ActionXCommand.handleNonTransient(ActionExecutor.Context context,
ActionExecutor executor,
WorkflowAction.Status status)
Takes care of non transient failures.
|
protected boolean |
ActionXCommand.handleTransient(ActionExecutor.Context context,
ActionExecutor executor,
WorkflowAction.Status status)
Takes care of Transient failures.
|
Copyright © 2016 Apache Software Foundation. All rights reserved.