Uses of Class
org.apache.oozie.command.CommandException

Packages that use CommandException
org.apache.oozie   
org.apache.oozie.command   
org.apache.oozie.command.bundle   
org.apache.oozie.command.coord   
org.apache.oozie.command.wf   
org.apache.oozie.util   
org.apache.oozie.util.db   
 

Uses of CommandException in org.apache.oozie
 

Methods in org.apache.oozie that throw CommandException
 void CoordinatorEngine.streamLog(String jobId, String logRetrievalScope, String logRetrievalType, Writer writer)
          Add list of actions to the filter based on conditions
 

Uses of CommandException in org.apache.oozie.command
 

Methods in org.apache.oozie.command that throw CommandException
 T XCommand.call()
          Implements the XCommand life-cycle.
 T Command.call()
          Execute the command #call(WorkflowStore) setting all the necessary context.
protected abstract  T Command.call(S store)
          DagCallable subclasses must implement this method to perform their task.
protected  void XCommand.eagerLoadState()
          Load the necessary state to perform an eager precondition check.
protected  void RerunTransitionXCommand.eagerLoadState()
           
protected  void XCommand.eagerVerifyPrecondition()
          Verify the precondition for the command before obtaining a lock.
protected  void RerunTransitionXCommand.eagerVerifyPrecondition()
           
protected abstract  T XCommand.execute()
          Command execution body.
protected  Void UnpauseTransitionXCommand.execute()
           
protected  T TransitionXCommand.execute()
           
protected  Void SuspendTransitionXCommand.execute()
           
protected  String SubmitTransitionXCommand.execute()
           
protected  Void StartTransitionXCommand.execute()
           
protected  Void ResumeTransitionXCommand.execute()
           
protected  T RerunTransitionXCommand.execute()
           
protected  Void PauseTransitionXCommand.execute()
           
protected  Void MaterializeTransitionXCommand.execute()
           
protected  Void KillTransitionXCommand.execute()
           
protected  T Command.execute(S store)
           
abstract  void KillTransitionXCommand.killChildren()
           
protected abstract  void XCommand.loadState()
          Load the necessary state to perform the precondition check and to execute the command.
protected abstract  void MaterializeTransitionXCommand.materialize()
          Materialize the actions for current job
abstract  void TransitionXCommand.notifyParent()
          This will be used to notify the parent about the status of that perticular job.
abstract  void PauseTransitionXCommand.pauseChildren()
          pause actions associated with the job
abstract  void RerunTransitionXCommand.rerunChildren()
          Rerun actions associated with the job
abstract  void ResumeTransitionXCommand.resumeChildren()
          Resume all children of the job
abstract  void StartTransitionXCommand.StartChildren()
          Start actions associated with the job
protected abstract  String SubmitTransitionXCommand.submit()
          Submit the job
abstract  void SuspendTransitionXCommand.suspendChildren()
          Suspend all children of the job
 void UnpauseTransitionXCommand.transitToNext()
           
abstract  void TransitionXCommand.transitToNext()
          Transit to the next status based on the result of the Job.
 void PauseTransitionXCommand.transitToNext()
           
 void MaterializeTransitionXCommand.transitToNext()
           
abstract  void UnpauseTransitionXCommand.unpauseChildren()
          Unpause actions associated with the job
abstract  void TransitionXCommand.updateJob()
          Update the parent job.
protected abstract  void XCommand.verifyPrecondition()
          Verify the precondition for the command after a lock has been obtain, just before executing the command.
protected  void RerunTransitionXCommand.verifyPrecondition()
           
 

Uses of CommandException in org.apache.oozie.command.bundle
 

Methods in org.apache.oozie.command.bundle that throw CommandException
protected  void BundleSubmitXCommand.eagerLoadState()
           
protected  void BundleStatusUpdateXCommand.eagerLoadState()
           
 void BundleStartXCommand.eagerLoadState()
           
protected  void BundleJobChangeXCommand.eagerLoadState()
           
protected  void BundleSubmitXCommand.eagerVerifyPrecondition()
           
protected  void BundleStartXCommand.eagerVerifyPrecondition()
           
protected  void BundleJobChangeXCommand.eagerVerifyPrecondition()
           
protected  Void BundleStatusUpdateXCommand.execute()
           
protected  Void BundlePurgeXCommand.execute()
           
protected  BundleJobBean BundleJobXCommand.execute()
           
protected  BundleJobInfo BundleJobsXCommand.execute()
           
protected  Void BundleJobChangeXCommand.execute()
           
 void BundleKillXCommand.killChildren()
           
 void BundleUnpauseXCommand.loadState()
           
protected  void BundleSubmitXCommand.loadState()
           
protected  void BundleStatusUpdateXCommand.loadState()
           
 void BundleStartXCommand.loadState()
           
protected  void BundleRerunXCommand.loadState()
           
protected  void BundlePurgeXCommand.loadState()
           
 void BundlePauseXCommand.loadState()
           
 void BundleKillXCommand.loadState()
           
protected  void BundleJobXCommand.loadState()
           
protected  void BundleJobsXCommand.loadState()
           
protected  void BundleJobSuspendXCommand.loadState()
           
protected  void BundleJobResumeXCommand.loadState()
           
protected  void BundleJobChangeXCommand.loadState()
           
protected  void BundleSubmitXCommand.mergeDefaultConfig()
          Merge default configuration with user-defined configuration.
 void BundleSubmitXCommand.notifyParent()
           
 void BundleRerunXCommand.notifyParent()
           
 void BundleJobSuspendXCommand.notifyParent()
           
 void BundleJobResumeXCommand.notifyParent()
           
 void BundlePauseXCommand.pauseChildren()
           
 void BundleRerunXCommand.rerunChildren()
           
 void BundleJobResumeXCommand.resumeChildren()
           
 void BundleStartXCommand.StartChildren()
           
protected  String BundleSubmitXCommand.submit()
           
 void BundleJobSuspendXCommand.suspendChildren()
           
 void BundleUnpauseXCommand.unpauseChildren()
           
 void BundleUnpauseXCommand.updateJob()
           
 void BundleSubmitXCommand.updateJob()
           
 void BundleStartXCommand.updateJob()
           
 void BundleRerunXCommand.updateJob()
           
 void BundlePauseXCommand.updateJob()
           
 void BundleKillXCommand.updateJob()
           
 void BundleJobSuspendXCommand.updateJob()
           
 void BundleJobResumeXCommand.updateJob()
           
protected  void BundleUnpauseXCommand.verifyPrecondition()
           
protected  void BundleSubmitXCommand.verifyPrecondition()
           
protected  void BundleStatusUpdateXCommand.verifyPrecondition()
           
protected  void BundleStartXCommand.verifyPrecondition()
           
protected  void BundlePurgeXCommand.verifyPrecondition()
           
protected  void BundlePauseXCommand.verifyPrecondition()
           
protected  void BundleKillXCommand.verifyPrecondition()
           
protected  void BundleJobXCommand.verifyPrecondition()
           
protected  void BundleJobsXCommand.verifyPrecondition()
           
protected  void BundleJobSuspendXCommand.verifyPrecondition()
           
protected  void BundleJobResumeXCommand.verifyPrecondition()
           
protected  void BundleJobChangeXCommand.verifyPrecondition()
           
 

Constructors in org.apache.oozie.command.bundle that throw CommandException
BundleJobChangeXCommand(String id, String changeValue)
           
 

Uses of CommandException in org.apache.oozie.command.coord
 

Methods in org.apache.oozie.command.coord that throw CommandException
protected  void CoordMaterializeTransitionXCommand.calcMatdTime()
          Calculate startMatdTime and endMatdTime from job's start time if next materialized time is null
protected  Void CoordSuspendCommand.call(CoordinatorStore store)
           
protected  String CoordSubmitCommand.call(CoordinatorStore store)
           
protected  Void CoordResumeCommand.call(CoordinatorStore store)
           
protected  CoordinatorActionInfo CoordRerunCommand.call(CoordinatorStore store)
           
protected  Void CoordPurgeCommand.call(CoordinatorStore store)
           
protected  Void CoordKillCommand.call(CoordinatorStore store)
           
protected  CoordinatorJobInfo CoordJobsCommand.call(CoordinatorStore store)
           
protected  Void CoordJobMatLookupCommand.call(CoordinatorStore store)
           
protected  CoordinatorJobBean CoordJobCommand.call(CoordinatorStore store)
           
protected  Void CoordChangeCommand.call(CoordinatorStore store)
           
protected  Void CoordActionUpdateCommand.call(CoordinatorStore cstore)
           
protected  Void CoordActionTimeOut.call(CoordinatorStore store)
           
protected  Void CoordActionStartCommand.call(CoordinatorStore store)
           
protected  Void CoordActionReadyCommand.call(CoordinatorStore store)
           
protected  Void CoordActionNotification.call(CoordinatorStore store)
           
protected  Void CoordActionMaterializeCommand.call(CoordinatorStore store)
           
protected  Void CoordActionInputCheckCommand.call(CoordinatorStore store)
           
protected  CoordinatorActionBean CoordActionInfoCommand.call(CoordinatorStore store)
           
protected  Void CoordActionCheckCommand.call(CoordinatorStore cstore)
           
protected  List<SLAEventBean> SLAEventsCommand.call(SLAStore store)
           
static void CoordCommandUtils.checkIfBothSameType(String startInst, String endInst)
           
protected  void CoordActionUpdateXCommand.eagerLoadState()
           
protected  void CoordActionStartXCommand.eagerLoadState()
           
protected  void CoordActionInputCheckXCommand.eagerLoadState()
           
protected  void CoordRerunXCommand.eagerVerifyPrecondition()
           
protected  void CoordActionUpdateXCommand.eagerVerifyPrecondition()
           
protected  List<SLAEventBean> SLAEventsXCommand.execute()
           
protected  Void CoordPurgeXCommand.execute()
           
protected  CoordinatorJobBean CoordJobXCommand.execute()
           
protected  CoordinatorJobInfo CoordJobsXCommand.execute()
           
protected  Void CoordChangeXCommand.execute()
           
protected  Void CoordActionUpdateXCommand.execute()
           
protected  Void CoordActionTimeOutXCommand.execute()
           
protected  Void CoordActionStartXCommand.execute()
           
protected  Void CoordActionReadyXCommand.execute()
           
protected  Void CoordActionNotificationXCommand.execute()
           
protected  Void CoordActionInputCheckXCommand.execute()
           
protected  CoordinatorActionBean CoordActionInfoXCommand.execute()
           
protected  Void CoordActionCheckXCommand.execute()
           
protected  Void CoordSuspendCommand.execute(CoordinatorStore store)
           
protected  Void CoordResumeCommand.execute(CoordinatorStore store)
           
protected  CoordinatorActionInfo CoordRerunCommand.execute(CoordinatorStore store)
           
protected  Void CoordRecoveryCommand.execute(CoordinatorStore store)
           
protected  Void CoordKillCommand.execute(CoordinatorStore store)
           
protected  Void CoordJobMatLookupCommand.execute(CoordinatorStore store)
           
protected  Void CoordChangeCommand.execute(CoordinatorStore store)
           
protected  Void CoordActionUpdateCommand.execute(CoordinatorStore store)
           
protected  Void CoordActionTimeOut.execute(CoordinatorStore store)
           
protected  Void CoordActionStartCommand.execute(CoordinatorStore store)
           
protected  Void CoordActionReadyCommand.execute(CoordinatorStore store)
           
protected  Void CoordActionMaterializeCommand.execute(CoordinatorStore store)
           
protected  Void CoordActionInputCheckCommand.execute(CoordinatorStore store)
           
protected  Void CoordActionCheckCommand.execute(CoordinatorStore store)
           
 void CoordKillXCommand.killChildren()
           
protected  void SLAEventsXCommand.loadState()
           
 void CoordUnpauseXCommand.loadState()
           
protected  void CoordSuspendXCommand.loadState()
           
protected  void CoordSubmitXCommand.loadState()
           
protected  void CoordResumeXCommand.loadState()
           
protected  void CoordRerunXCommand.loadState()
           
protected  void CoordPurgeXCommand.loadState()
           
 void CoordPauseXCommand.loadState()
           
protected  void CoordMaterializeTransitionXCommand.loadState()
           
protected  void CoordKillXCommand.loadState()
           
protected  void CoordJobXCommand.loadState()
           
protected  void CoordJobsXCommand.loadState()
           
protected  void CoordChangeXCommand.loadState()
           
protected  void CoordActionUpdateXCommand.loadState()
           
protected  void CoordActionTimeOutXCommand.loadState()
           
protected  void CoordActionStartXCommand.loadState()
           
protected  void CoordActionReadyXCommand.loadState()
           
protected  void CoordActionNotificationXCommand.loadState()
           
protected  void CoordActionInputCheckXCommand.loadState()
           
protected  void CoordActionInfoXCommand.loadState()
           
protected  void CoordActionCheckXCommand.loadState()
           
protected  void CoordMaterializeTransitionXCommand.materialize()
           
protected  void CoordSubmitXCommand.mergeDefaultConfig()
          Merge default configuration with user-defined configuration.
protected  void CoordSubmitCommand.mergeDefaultConfig()
          Merge default configuration with user-defined configuration.
 void CoordUnpauseXCommand.notifyParent()
           
 void CoordSuspendXCommand.notifyParent()
           
 void CoordSubmitXCommand.notifyParent()
           
 void CoordResumeXCommand.notifyParent()
           
 void CoordRerunXCommand.notifyParent()
           
 void CoordPauseXCommand.notifyParent()
           
 void CoordMaterializeTransitionXCommand.notifyParent()
           
 void CoordKillXCommand.notifyParent()
           
 void CoordPauseXCommand.pauseChildren()
           
 void CoordRerunXCommand.rerunChildren()
           
 void CoordResumeXCommand.resumeChildren()
           
protected  String CoordSubmitXCommand.submit()
           
 void CoordSuspendXCommand.suspendChildren()
           
 void CoordMaterializeTransitionXCommand.transitToNext()
           
 void CoordUnpauseXCommand.unpauseChildren()
           
 void CoordUnpauseXCommand.updateJob()
           
 void CoordSuspendXCommand.updateJob()
           
 void CoordSubmitXCommand.updateJob()
           
 void CoordResumeXCommand.updateJob()
           
 void CoordRerunXCommand.updateJob()
           
 void CoordPauseXCommand.updateJob()
           
 void CoordMaterializeTransitionXCommand.updateJob()
           
 void CoordKillXCommand.updateJob()
           
protected  void SLAEventsXCommand.verifyPrecondition()
           
protected  void CoordUnpauseXCommand.verifyPrecondition()
           
protected  void CoordSuspendXCommand.verifyPrecondition()
           
protected  void CoordSubmitXCommand.verifyPrecondition()
           
protected  void CoordResumeXCommand.verifyPrecondition()
           
protected  void CoordRerunXCommand.verifyPrecondition()
           
protected  void CoordPurgeXCommand.verifyPrecondition()
           
protected  void CoordPauseXCommand.verifyPrecondition()
           
protected  void CoordMaterializeTransitionXCommand.verifyPrecondition()
           
protected  void CoordKillXCommand.verifyPrecondition()
           
protected  void CoordJobXCommand.verifyPrecondition()
           
protected  void CoordJobsXCommand.verifyPrecondition()
           
protected  void CoordChangeXCommand.verifyPrecondition()
           
protected  void CoordActionUpdateXCommand.verifyPrecondition()
           
protected  void CoordActionTimeOutXCommand.verifyPrecondition()
           
protected  void CoordActionReadyXCommand.verifyPrecondition()
           
protected  void CoordActionNotificationXCommand.verifyPrecondition()
           
protected  void CoordActionInputCheckXCommand.verifyPrecondition()
           
protected  void CoordActionInfoXCommand.verifyPrecondition()
           
protected  void CoordActionCheckXCommand.verifyPrecondition()
           
 

Constructors in org.apache.oozie.command.coord that throw CommandException
CoordChangeCommand(String id, String changeValue)
           
CoordChangeXCommand(String id, String changeValue)
          This command is used to update the Coordinator job with the new values Update the coordinator job bean and update that to database.
 

Uses of CommandException in org.apache.oozie.command.wf
 

Methods in org.apache.oozie.command.wf that throw CommandException
protected  Void SuspendCommand.call(WorkflowStore store)
           
protected  String SubmitHttpCommand.call(WorkflowStore store)
           
protected  String SubmitCommand.call(WorkflowStore store)
           
protected  Void SignalCommand.call(WorkflowStore store)
           
protected  Void ResumeCommand.call(WorkflowStore store)
           
protected  Void ReRunCommand.call(WorkflowStore store)
           
protected  Void PurgeCommand.call(WorkflowStore store)
           
protected  Void KillCommand.call(WorkflowStore store)
           
protected  String ExternalIdCommand.call(WorkflowStore store)
           
protected  Void CompletedActionCommand.call(WorkflowStore store)
           
protected  Void ActionStartCommand.call(WorkflowStore store)
           
protected  Void ActionKillCommand.call(WorkflowStore store)
           
protected  Void ActionEndCommand.call(WorkflowStore store)
           
protected  Void ActionCheckCommand.call(WorkflowStore store)
           
protected  void SuspendXCommand.eagerLoadState()
           
protected  void ReRunXCommand.eagerLoadState()
          Loading the Wfjob and workflow actions.
protected  void CompletedActionXCommand.eagerLoadState()
           
protected  void ActionCheckXCommand.eagerLoadState()
           
protected  void SuspendXCommand.eagerVerifyPrecondition()
           
protected  void ReRunXCommand.eagerVerifyPrecondition()
          Checks the pre-conditions that are required for workflow to recover - Last run of Workflow should be completed - The nodes that are to be skipped are to be completed successfully in the base run.
protected  void CompletedActionXCommand.eagerVerifyPrecondition()
           
protected  void ActionCheckXCommand.eagerVerifyPrecondition()
           
protected  WorkflowActionBean WorkflowActionInfoXCommand.execute()
           
protected  Void WfEndXCommand.execute()
           
protected  Void SuspendXCommand.execute()
           
protected  String SubmitXCommand.execute()
           
protected  String SubmitHttpXCommand.execute()
           
protected  Void SignalXCommand.execute()
           
protected  Void ResumeXCommand.execute()
           
protected  Void ReRunXCommand.execute()
           
protected  Void PurgeXCommand.execute()
           
protected  Void NotificationXCommand.execute()
           
protected  Void KillXCommand.execute()
           
protected  WorkflowJobBean JobXCommand.execute()
           
protected  WorkflowsInfo JobsXCommand.execute()
           
protected  String ExternalIdXCommand.execute()
           
protected  String DefinitionXCommand.execute()
           
protected  Void CompletedActionXCommand.execute()
           
protected  Void ActionStartXCommand.execute()
           
protected  Void ActionKillXCommand.execute()
           
protected  Void ActionEndXCommand.execute()
           
protected  Void ActionCheckXCommand.execute()
           
protected  Void SuspendCommand.execute(WorkflowStore store)
           
protected  Void SignalCommand.execute(WorkflowStore store)
           
protected  Void ResumeCommand.execute(WorkflowStore store)
           
protected  Void ReRunCommand.execute(WorkflowStore store)
           
protected  Void KillCommand.execute(WorkflowStore store)
           
protected  Void ActionStartCommand.execute(WorkflowStore store)
           
protected  Void ActionKillCommand.execute(WorkflowStore store)
           
protected  Void ActionEndCommand.execute(WorkflowStore store)
           
protected  Void ActionCheckCommand.execute(WorkflowStore store)
           
 void ActionXCommand.failJob(ActionExecutor.Context context)
          Fail the job due to failed action
 void ActionCommand.failJob(ActionExecutor.Context context)
           
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 ActionCommand.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  void ActionCommand.handleNonTransient(WorkflowStore store, 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.
protected  boolean ActionCommand.handleTransient(ActionExecutor.Context context, ActionExecutor executor, org.apache.oozie.client.WorkflowAction.Status status)
          Takes care of Transient failures.
 boolean ActionXCommand.handleUserRetry(WorkflowActionBean action)
          Execute retry for action if this action is eligible for user-retry
protected  void WfEndXCommand.loadState()
           
protected  void SuspendXCommand.loadState()
           
protected  void SignalXCommand.loadState()
           
protected  void ResumeXCommand.loadState()
           
protected  void ReRunXCommand.loadState()
           
protected  void PurgeXCommand.loadState()
           
protected  void NotificationXCommand.loadState()
           
protected  void KillXCommand.loadState()
           
protected  void JobXCommand.loadState()
           
protected  void JobsXCommand.loadState()
           
protected  void ExternalIdXCommand.loadState()
           
protected  void DefinitionXCommand.loadState()
           
protected  void CompletedActionXCommand.loadState()
           
protected  void ActionStartXCommand.loadState()
           
protected  void ActionKillXCommand.loadState()
           
protected  void ActionEndXCommand.loadState()
           
protected  void ActionCheckXCommand.loadState()
           
static String SubmitXCommand.resolveSla(org.jdom.Element eSla, ELEvaluator evalSla)
          Resolve variables in sla xml element.
static String SubmitCommand.resolveSla(org.jdom.Element eSla, ELEvaluator evalSla)
           
static void SuspendXCommand.suspendJob(JPAService jpaService, WorkflowJobBean workflow, String id, String actionId)
          Suspend the workflow job and pending flag to false for the actions that are START_RETRY or START_MANUAL or END_RETRY or END_MANUAL
protected  void WorkflowActionInfoXCommand.verifyPrecondition()
           
protected  void WfEndXCommand.verifyPrecondition()
           
protected  void SuspendXCommand.verifyPrecondition()
           
protected  void SubmitXCommand.verifyPrecondition()
           
protected  void SubmitPigXCommand.verifyPrecondition()
           
protected  void SubmitMRXCommand.verifyPrecondition()
           
protected  void SignalXCommand.verifyPrecondition()
           
protected  void ResumeXCommand.verifyPrecondition()
           
protected  void ReRunXCommand.verifyPrecondition()
           
protected  void PurgeXCommand.verifyPrecondition()
           
protected  void NotificationXCommand.verifyPrecondition()
           
protected  void KillXCommand.verifyPrecondition()
           
protected  void JobXCommand.verifyPrecondition()
           
protected  void JobsXCommand.verifyPrecondition()
           
protected  void ExternalIdXCommand.verifyPrecondition()
           
protected  void DefinitionXCommand.verifyPrecondition()
           
protected  void CompletedActionXCommand.verifyPrecondition()
           
protected  void ActionStartXCommand.verifyPrecondition()
           
protected  void ActionKillXCommand.verifyPrecondition()
           
protected  void ActionEndXCommand.verifyPrecondition()
           
protected  void ActionCheckXCommand.verifyPrecondition()
           
 

Uses of CommandException in org.apache.oozie.util
 

Methods in org.apache.oozie.util that throw CommandException
static void PropertiesUtils.checkDisallowedProperties(org.apache.hadoop.conf.Configuration conf, Set<String> set)
          Validate against DISALLOWED Properties.
static Map<String,String> JobUtils.parseChangeValue(String changeValue)
          This Function will parse the value of the changed values in key value manner.
 

Uses of CommandException in org.apache.oozie.util.db
 

Methods in org.apache.oozie.util.db that throw CommandException
static void SLADbXOperations.writeStausEvent(String slaXml, String id, org.apache.oozie.client.SLAEvent.Status stat, org.apache.oozie.client.SLAEvent.SlaAppType appType)
          Create SLA status event
static void SLADbOperations.writeStausEvent(String slaXml, String id, org.apache.oozie.client.SLAEvent.Status stat, org.apache.oozie.client.SLAEvent.SlaAppType appType, XLog log)
           
static void SLADbOperations.writeStausEvent(String slaXml, String id, Store store, org.apache.oozie.client.SLAEvent.Status stat, org.apache.oozie.client.SLAEvent.SlaAppType appType)
           
 



Copyright © 2012 Apache Software Foundation. All Rights Reserved.