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.coord   
org.apache.oozie.dependency   
org.apache.oozie.sla   
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 PurgeXCommand.execute()
           
protected  Void PauseTransitionXCommand.execute()
           
protected  Void MaterializeTransitionXCommand.execute()
           
protected  Void KillTransitionXCommand.execute()
           
protected  BulkResponseInfo BulkJobsXCommand.execute()
           
protected  T Command.execute(S store)
           
 void TransitionXCommand.generateEvents(CoordinatorJobBean coordJob)
          This will be used to generate Job Notification events on status changes
abstract  void KillTransitionXCommand.killChildren()
           
protected abstract  void XCommand.loadState()
          Load the necessary state to perform the precondition check and to execute the command.
protected  void PurgeXCommand.loadState()
           
protected  void BulkJobsXCommand.loadState()
           
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 TransitionXCommand.performWrites()
          This will be used to perform atomically all the writes within this command.
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()
           
protected  void PurgeXCommand.verifyPrecondition()
           
protected  void BulkJobsXCommand.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  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()
           
 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 BundleUnpauseXCommand.performWrites()
           
 void BundleSubmitXCommand.performWrites()
           
 void BundleStartXCommand.performWrites()
           
 void BundleRerunXCommand.performWrites()
           
 void BundlePauseXCommand.performWrites()
           
 void BundleKillXCommand.performWrites()
           
 void BundleJobSuspendXCommand.performWrites()
           
 void BundleJobResumeXCommand.performWrites()
           
 void BundleRerunXCommand.rerunChildren()
           
 void BundleStartXCommand.StartChildren()
           
protected  String BundleSubmitXCommand.submit()
           
 void BundleJobSuspendXCommand.suspendChildren()
           
 void BundleUnpauseXCommand.unpauseChildren()
           
 void BundleUnpauseXCommand.updateJob()
           
 void BundleSubmitXCommand.updateJob()
           
 void BundleStartXCommand.updateJob()
           
 void BundlePauseXCommand.updateJob()
           
protected  void BundleUnpauseXCommand.verifyPrecondition()
           
protected  void BundleSubmitXCommand.verifyPrecondition()
           
protected  void BundleStatusUpdateXCommand.verifyPrecondition()
           
protected  void BundleStartXCommand.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 CoordActionMaterializeCommand.call(CoordinatorStore store)
           
static void CoordCommandUtils.checkIfBothSameType(String startInst, String endInst)
           
protected  void CoordPushDependencyCheckXCommand.eagerLoadState()
           
protected  void CoordActionUpdateXCommand.eagerLoadState()
           
protected  void CoordActionStartXCommand.eagerLoadState()
           
protected  void CoordRerunXCommand.eagerVerifyPrecondition()
           
protected  void CoordPushDependencyCheckXCommand.eagerVerifyPrecondition()
           
protected  void CoordActionUpdateXCommand.eagerVerifyPrecondition()
           
protected  List<SLAEventBean> SLAEventsXCommand.execute()
           
protected  Void CoordPushDependencyCheckXCommand.execute()
           
protected  CoordinatorJobBean CoordJobXCommand.execute()
           
protected  CoordinatorJobInfo CoordJobsXCommand.execute()
           
protected  Void CoordChangeXCommand.execute()
           
protected  Void CoordActionUpdateXCommand.execute()
           
protected  Void CoordActionUpdatePushMissingDependency.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 CoordActionMaterializeCommand.execute(CoordinatorStore store)
           
static List<CoordinatorActionBean> CoordRerunXCommand.getCoordActions(String rerunType, String jobId, String scope)
          Get the list of actions for a given coordinator job
 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 CoordPushDependencyCheckXCommand.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.
 void CoordUnpauseXCommand.notifyParent()
           
 void CoordSuspendXCommand.notifyParent()
           
 void CoordSubmitXCommand.notifyParent()
           
 void CoordResumeXCommand.notifyParent()
           
 void CoordRerunXCommand.notifyParent()
           
 void CoordPauseXCommand.notifyParent()
           
 void CoordMaterializeTransitionXCommand.notifyParent()
           
 void CoordKillXCommand.notifyParent()
           
protected  void CoordPushDependencyCheckXCommand.onAllPushDependenciesAvailable()
           
 void CoordPauseXCommand.pauseChildren()
           
 void CoordUnpauseXCommand.performWrites()
           
 void CoordSuspendXCommand.performWrites()
           
 void CoordSubmitXCommand.performWrites()
           
 void CoordResumeXCommand.performWrites()
           
 void CoordRerunXCommand.performWrites()
           
 void CoordPauseXCommand.performWrites()
           
 void CoordMaterializeTransitionXCommand.performWrites()
           
 void CoordKillXCommand.performWrites()
           
 void CoordRerunXCommand.rerunChildren()
           
 void CoordResumeXCommand.resumeChildren()
           
protected  String CoordSubmitXCommand.submit()
           
 void CoordSuspendXCommand.suspendChildren()
           
 void CoordMaterializeTransitionXCommand.transitToNext()
           
 void CoordUnpauseXCommand.unpauseChildren()
           
protected  void CoordPushDependencyCheckXCommand.updateCoordAction(CoordinatorActionBean coordAction, boolean isChangeInDependency)
           
 void CoordUnpauseXCommand.updateJob()
           
 void CoordSubmitXCommand.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 CoordPushDependencyCheckXCommand.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
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 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 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()
           
 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.
 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 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 void SuspendXCommand.suspendJob(JPAService jpaService, WorkflowJobBean workflow, String id, String actionId, List<JsonBean> updateList)
          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 SubmitScriptLanguageXCommand.verifyPrecondition()
           
protected  void SubmitMRXCommand.verifyPrecondition()
           
protected  void SignalXCommand.verifyPrecondition()
           
protected  void ResumeXCommand.verifyPrecondition()
           
protected  void ReRunXCommand.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.coord
 

Methods in org.apache.oozie.coord that throw CommandException
static List<CoordinatorActionBean> CoordUtils.getCoordActionsFromDates(String jobId, String scope)
          Get the list of actions for given date ranges
static List<CoordinatorActionBean> CoordUtils.getCoordActionsFromIds(String jobId, String scope)
          Get the list of actions for given id ranges
 

Uses of CommandException in org.apache.oozie.dependency
 

Methods in org.apache.oozie.dependency that throw CommandException
static ActionDependency DependencyChecker.checkForAvailability(String[] missingDependencies, org.apache.hadoop.conf.Configuration actionConf, boolean stopOnFirstMissing)
          Get the currently missing and available dependencies after checking the list of known missing dependencies against the source.
static ActionDependency DependencyChecker.checkForAvailability(String missingDependencies, org.apache.hadoop.conf.Configuration actionConf, boolean stopOnFirstMissing)
          Get the currently missing and available dependencies after checking the list of known missing dependencies against the source.
 

Uses of CommandException in org.apache.oozie.sla
 

Methods in org.apache.oozie.sla that throw CommandException
static SLARegistrationBean SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla, String jobId, org.apache.oozie.AppType appType, String user, String appName, XLog log)
           
static SLARegistrationBean SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla, String jobId, org.apache.oozie.AppType appType, String user, XLog log)
           
static SLARegistrationBean SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla, String jobId, String parentId, org.apache.oozie.AppType appType, String user, String appName, XLog log, boolean rerun)
           
static SLARegistrationBean SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla, String jobId, String parentId, org.apache.oozie.AppType appType, String user, XLog log)
           
static void SLAOperations.updateRegistrationEvent(String jobId)
          Retrieve registration event
 

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 SLAEventBean SLADbXOperations.createStatusEvent(String slaXml, String id, org.apache.oozie.client.SLAEvent.Status stat, org.apache.oozie.client.SLAEvent.SlaAppType appType)
          Deprecated. Create SLA status event
static SLAEventBean SLADbOperations.createStatusEvent(String slaXml, String id, org.apache.oozie.client.SLAEvent.Status stat, org.apache.oozie.client.SLAEvent.SlaAppType appType, XLog log)
          Deprecated.  
 



Copyright © 2013 Apache Software Foundation. All Rights Reserved.