Uses of Interface
org.apache.oozie.action.ActionExecutor.Context

Packages that use ActionExecutor.Context
org.apache.oozie.action   
org.apache.oozie.action.control   
org.apache.oozie.action.decision   
org.apache.oozie.action.email   
org.apache.oozie.action.hadoop   
org.apache.oozie.action.oozie   
org.apache.oozie.action.ssh   
org.apache.oozie.command.wf   
 

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 SqoopActionExecutor.end(ActionExecutor.Context context, org.apache.oozie.client.WorkflowAction action)
          We will gather counters from all executed action Hadoop jobs (e.g.
 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 SqoopActionExecutor.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
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  void HiveActionExecutor.getActionData(org.apache.hadoop.fs.FileSystem actionFs, org.apache.hadoop.mapred.RunningJob runningJob, org.apache.oozie.client.WorkflowAction action, ActionExecutor.Context context)
           
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, org.apache.oozie.client.WorkflowAction action, org.apache.hadoop.mapred.JobClient jobClient)
           
protected  org.apache.hadoop.mapred.RunningJob JavaActionExecutor.getRunningJob(ActionExecutor.Context context, org.apache.oozie.client.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.
 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  void PigActionExecutor.setActionCompletionData(ActionExecutor.Context context, org.apache.hadoop.fs.FileSystem fs)
           
protected  void JavaActionExecutor.setActionCompletionData(ActionExecutor.Context context, org.apache.hadoop.fs.FileSystem actionFs)
          Sets some data for the action on completion
protected  void HiveActionExecutor.setActionCompletionData(ActionExecutor.Context context, org.apache.hadoop.fs.FileSystem actionFs)
           
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 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, 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
 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, 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.
 



Copyright © 2013 Apache Software Foundation. All Rights Reserved.