|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of ActionExecutor.Context in org.apache.oozie.action |
---|
Methods in org.apache.oozie.action with parameters of type ActionExecutor.Context | |
---|---|
abstract void |
ActionExecutor.check(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
Check if an action has completed. |
abstract void |
ActionExecutor.end(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
End an action after it has executed. |
abstract void |
ActionExecutor.kill(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
Kill an action. |
abstract void |
ActionExecutor.start(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
Start an action. |
Uses of ActionExecutor.Context in org.apache.oozie.action.control |
---|
Methods in org.apache.oozie.action.control with parameters of type ActionExecutor.Context | |
---|---|
void |
ControlNodeActionExecutor.check(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
void |
ControlNodeActionExecutor.end(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
void |
ControlNodeActionExecutor.kill(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
void |
ControlNodeActionExecutor.start(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
Uses of ActionExecutor.Context in org.apache.oozie.action.decision |
---|
Methods in org.apache.oozie.action.decision with parameters of type ActionExecutor.Context | |
---|---|
void |
DecisionActionExecutor.check(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
void |
DecisionActionExecutor.end(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
void |
DecisionActionExecutor.kill(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
void |
DecisionActionExecutor.start(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
Uses of ActionExecutor.Context in org.apache.oozie.action.email |
---|
Methods in org.apache.oozie.action.email with parameters of type ActionExecutor.Context | |
---|---|
void |
EmailActionExecutor.check(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
protected void |
EmailActionExecutor.email(ActionExecutor.Context context,
String[] to,
String[] cc,
String subject,
String body)
|
void |
EmailActionExecutor.end(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
void |
EmailActionExecutor.kill(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
void |
EmailActionExecutor.start(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
protected void |
EmailActionExecutor.validateAndMail(ActionExecutor.Context context,
org.jdom.Element element)
|
Uses of ActionExecutor.Context in org.apache.oozie.action.hadoop |
---|
Methods in org.apache.oozie.action.hadoop with parameters of type ActionExecutor.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,
org.apache.oozie.client.WorkflowAction action)
|
void |
FsActionExecutor.check(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
org.apache.hadoop.mapred.JobConf |
JavaActionExecutor.createBaseHadoopConf(ActionExecutor.Context context,
org.jdom.Element actionXml)
|
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)
Delete path |
void |
MapReduceActionExecutor.end(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
void |
JavaActionExecutor.end(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
void |
FsActionExecutor.end(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
protected HashMap<String,CredentialsProperties> |
JavaActionExecutor.getActionCredentialsProperties(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
protected void |
PigActionExecutor.getActionData(org.apache.hadoop.fs.FileSystem actionFs,
org.apache.hadoop.mapred.RunningJob runningJob,
org.apache.oozie.client.WorkflowAction action,
ActionExecutor.Context context)
Get the stats and external child IDs for a pig job |
protected void |
JavaActionExecutor.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 CredentialsProperties |
JavaActionExecutor.getCredProperties(ActionExecutor.Context context,
String credName)
|
org.apache.hadoop.fs.Path |
FsActionExecutor.getRecoveryPath(ActionExecutor.Context context)
|
protected String |
JavaActionExecutor.getShareLibName(ActionExecutor.Context context,
org.jdom.Element actionXml,
org.apache.hadoop.conf.Configuration conf)
Return the sharelib name for the action. |
void |
JavaActionExecutor.kill(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
void |
FsActionExecutor.kill(ActionExecutor.Context context,
org.apache.oozie.client.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)
|
void |
JavaActionExecutor.prepareActionDir(org.apache.hadoop.fs.FileSystem actionFs,
ActionExecutor.Context context)
|
protected HashMap<String,CredentialsProperties> |
JavaActionExecutor.setCredentialPropertyToActionConf(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action,
org.apache.hadoop.conf.Configuration actionConf)
|
protected void |
JavaActionExecutor.setCredentialTokens(org.apache.hadoop.mapred.JobConf jobconf,
ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action,
HashMap<String,CredentialsProperties> credPropertiesMap)
|
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 |
PigActionExecutor.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 |
HiveActionExecutor.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,
org.apache.oozie.client.WorkflowAction action)
|
void |
FsActionExecutor.start(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
void |
JavaActionExecutor.submitLauncher(org.apache.hadoop.fs.FileSystem actionFs,
ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
Uses of ActionExecutor.Context in org.apache.oozie.action.oozie |
---|
Methods in org.apache.oozie.action.oozie with parameters of type ActionExecutor.Context | |
---|---|
void |
SubWorkflowActionExecutor.check(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
void |
SubWorkflowActionExecutor.end(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
protected org.apache.oozie.client.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,
org.apache.oozie.client.WorkflowAction action)
|
void |
SubWorkflowActionExecutor.start(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
|
Uses of ActionExecutor.Context in org.apache.oozie.action.ssh |
---|
Methods in org.apache.oozie.action.ssh with parameters of type ActionExecutor.Context | |
---|---|
void |
SshActionExecutor.check(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
Check ssh action status. |
void |
SshActionExecutor.end(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
End action execution. |
protected org.apache.oozie.client.WorkflowAction.Status |
SshActionExecutor.getActionStatus(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
Get action status. |
String |
SshActionExecutor.getRemoteFileName(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action,
String fileExtension,
boolean dirOnly,
boolean useExtId)
Get remote host working location. |
void |
SshActionExecutor.kill(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
Kill ssh action. |
protected String |
SshActionExecutor.setupRemote(String host,
ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
Do ssh action execution setup on remote host. |
void |
SshActionExecutor.start(ActionExecutor.Context context,
org.apache.oozie.client.WorkflowAction action)
Start the ssh action execution. |
Uses of ActionExecutor.Context in org.apache.oozie.command.wf |
---|
Classes in org.apache.oozie.command.wf that implement ActionExecutor.Context | |
---|---|
static class |
ActionXCommand.ActionExecutorContext
Workflow action executor context |
Methods in org.apache.oozie.command.wf with parameters of type ActionExecutor.Context | |
---|---|
void |
ActionXCommand.failJob(ActionExecutor.Context context)
Fail the job due to failed action |
protected void |
ActionXCommand.handleError(ActionExecutor.Context context,
ActionExecutor executor,
String message,
boolean isStart,
org.apache.oozie.client.WorkflowAction.Status status)
Takes care of errors. |
protected void |
ActionXCommand.handleNonTransient(ActionExecutor.Context context,
ActionExecutor executor,
org.apache.oozie.client.WorkflowAction.Status status)
Takes care of non transient failures. |
protected boolean |
ActionXCommand.handleTransient(ActionExecutor.Context context,
ActionExecutor executor,
org.apache.oozie.client.WorkflowAction.Status status)
Takes care of Transient failures. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |