Uses of Interface
org.apache.oozie.util.XCallable

Packages that use XCallable
org.apache.oozie.command   
org.apache.oozie.command.bundle   
org.apache.oozie.command.coord   
org.apache.oozie.command.wf   
org.apache.oozie.service   
 

Uses of XCallable in org.apache.oozie.command
 

Classes in org.apache.oozie.command that implement XCallable
 class BulkJobsXCommand
          The command to get a job info for a list of bundle jobs by given filters.
 class Command<T,S extends Store>
          Base class for all synchronous and asynchronous DagEngine commands.
 class KillTransitionXCommand
          This is transition Base commands for all the jobs.
 class MaterializeTransitionXCommand
          Transition command for materialize the job.
 class PauseTransitionXCommand
          Transition command for pause the job.
 class RerunTransitionXCommand<T>
          Transition command for rerun the job.
 class ResumeTransitionXCommand
           
 class StartTransitionXCommand
          Transition command for start the job.
 class StatusUpdateXCommand
          Transition command for update status.
 class SubmitTransitionXCommand
          Base class for submit transition command.
 class SuspendTransitionXCommand
           
 class TransitionXCommand<T>
          This is the base commands for all the jobs related commands .
 class UnpauseTransitionXCommand
          Transition command for unpause the job.
 class XCommand<T>
          Base class for synchronous and asynchronous commands.
 

Methods in org.apache.oozie.command with parameters of type XCallable
protected  void Command.queueCallable(XCallable<Void> callable)
          Queue a callable for execution after the current callable call invocation completes and the WorkflowStore transaction commits.
protected  void Command.queueCallable(XCallable<Void> callable, long delay)
          Queue a callable for delayed execution after the current callable call invocation completes and the WorkflowStore transaction commits.
protected  void Command.queueCallableForException(XCallable<Void> callable)
          Queue a callable for execution only in the event of an exception being thrown during the call invocation.
 

Method parameters in org.apache.oozie.command with type arguments of type XCallable
protected  void Command.logQueueCallableFalse(List<? extends XCallable<Void>> callables)
          Logging the info if failed to queue the callables.
protected  void Command.queueCallable(List<? extends XCallable<Void>> callables)
          Queue a list of callables for execution after the current callable call invocation completes and the WorkflowStore transaction commits.
 

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

Classes in org.apache.oozie.command.bundle that implement XCallable
 class BundleJobChangeXCommand
           
 class BundleJobResumeXCommand
           
 class BundleJobSuspendXCommand
           
 class BundleJobsXCommand
          The command to get a job info for a list of bundle jobs by given filters.
 class BundleJobXCommand
          Command for Getting the Bundle job bean it also gets coordinators information in the Bundle job.
 class BundleKillXCommand
           
 class BundlePauseXCommand
           
 class BundlePurgeXCommand
          This class is used for bundle purge command
 class BundleRerunXCommand
          Rerun bundle coordinator jobs by a list of coordinator names or dates.
 class BundleStartXCommand
          The command to start Bundle job
 class BundleStatusUpdateXCommand
          The command to update Bundle status
 class BundleSubmitXCommand
          This Command will submit the bundle.
 class BundleUnpauseXCommand
           
 

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

Classes in org.apache.oozie.command.coord that implement XCallable
 class CoordActionCheckXCommand
          The command checks workflow status for coordinator action.
 class CoordActionInfoXCommand
           
 class CoordActionInputCheckXCommand
          The command to check if an action's data input paths exist in the file system.
 class CoordActionMaterializeCommand
           
 class CoordActionNotificationXCommand
          This class will send the notification for the coordinator action
 class CoordActionReadyXCommand
           
 class CoordActionStartXCommand
           
 class CoordActionTimeOutXCommand
          This class updates the Time out in the action bean
 class CoordActionUpdateXCommand
           
 class CoordChangeXCommand
           
 class CoordinatorCommand<T>
           
 class CoordinatorXCommand<T>
          Abstract coordinator command class derived from XCommand
 class CoordJobsXCommand
          The command to get a job info for a list of coordinator jobs by given filters.
 class CoordJobXCommand
          Command for loading a coordinator job information
 class CoordKillXCommand
           
 class CoordMaterializeTransitionXCommand
          Materialize actions for specified start and end time for coordinator job.
 class CoordPauseXCommand
           
 class CoordPurgeXCommand
          This class is used for coordinator purge command
 class CoordRerunXCommand
          Rerun coordinator actions by a list of dates or ids.
 class CoordResumeXCommand
          Resume coordinator job and actions.
 class CoordSubmitXCommand
          This class provides the functionalities to resolve a coordinator job XML and write the job information into a DB table.
 class CoordSuspendXCommand
          Suspend coordinator job and actions.
 class CoordUnpauseXCommand
           
 class SLAEventsXCommand
          The command to get a list of SLAEvents which are greater than given seqId.
 

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

Classes in org.apache.oozie.command.wf that implement XCallable
 class ActionCheckXCommand
          Executes the check command for ActionHandlers.
 class ActionEndXCommand
           
 class ActionKillXCommand
          Kill workflow action and invoke action executor to kill the underlying context.
 class ActionStartXCommand
           
 class ActionXCommand<T>
          Base class for Action execution commands.
 class CompletedActionXCommand
          This command is executed once the Workflow command is finished.
 class DefinitionXCommand
           
 class ExternalIdXCommand
           
 class JobsXCommand
           
 class JobXCommand
          This Xcommand is returning the workflow with action within the range.
 class KillXCommand
          Kill workflow job and its workflow instance and queue a WorkflowActionKillXCommand to kill the workflow actions.
 class NotificationXCommand
           
 class PurgeXCommand
           
 class ReRunXCommand
          This is a RerunXCommand which is used for rerunn.
 class ResumeXCommand
           
 class SignalXCommand
           
 class StartXCommand
          Starting the command.
 class SubmitHttpXCommand
           
 class SubmitMRXCommand
           
 class SubmitPigXCommand
           
 class SubmitXCommand
           
 class SuspendXCommand
           
 class WfEndXCommand
          This Command is expected to be called when a Workflow moves to any terminal state ( such as SUCCEEDED, KILLED, FAILED).
 class WorkflowActionInfoXCommand
           
 class WorkflowXCommand<T>
          Abstract coordinator command class derived from XCommand
 

Uses of XCallable in org.apache.oozie.service
 

Methods in org.apache.oozie.service that return types with arguments of type XCallable
 Set<XCallable<?>> CallableQueueService.checkInterrupts(String lockKey)
          check the interrupt map for the existence of an interrupt commands if exist a List of Interrupt Callable for the same lock key will bereturned, otherwise it will return null
 

Methods in org.apache.oozie.service with parameters of type XCallable
 void CallableQueueService.checkInterruptTypes(XCallable<?> callable)
          check if the callable is of an interrupt type and insert it into the map accordingly
 void CallableQueueService.insertCallableIntoInterruptMap(XCallable<?> callable)
          insert a new callable in the Interrupt Command Map add a new element to the list or create a new list accordingly
 boolean CallableQueueService.queue(XCallable<?> callable)
          Queue a callable for asynchronous execution.
 boolean CallableQueueService.queue(XCallable<?> callable, long delay)
          Queue a callable for asynchronous execution sometime in the future.
 

Method parameters in org.apache.oozie.service with type arguments of type XCallable
 boolean CallableQueueService.queueSerial(List<? extends XCallable<?>> callables)
          Queue a list of callables for serial execution.
 boolean CallableQueueService.queueSerial(List<? extends XCallable<?>> callables, long delay)
          Queue a list of callables for serial execution sometime in the future.
 



Copyright © 2013 Apache Software Foundation. All Rights Reserved.