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	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	CoordActionCheckCommand
class	CoordActionCheckXCommand The command checks workflow status for coordinator action.
class	CoordActionInfoCommand
class	CoordActionInfoXCommand
class	CoordActionInputCheckCommand
class	CoordActionInputCheckXCommand The command to check if an action's data input paths exist in the file system.
class	CoordActionMaterializeCommand
class	CoordActionNotification
class	CoordActionNotificationXCommand This class will send the notification for the coordinator action
class	CoordActionReadyCommand
class	CoordActionReadyXCommand
class	CoordActionStartCommand
class	CoordActionStartXCommand
class	CoordActionTimeOut
class	CoordActionTimeOutXCommand This class updates the Time out in the action bean
class	CoordActionUpdateCommand
class	CoordActionUpdateXCommand
class	CoordChangeCommand
class	CoordChangeXCommand
class	CoordinatorCommand<T>
class	CoordinatorXCommand<T> Abstract coordinator command class derived from XCommand
class	CoordJobCommand Command for loading a coordinator job information
class	CoordJobMatLookupCommand
class	CoordJobsCommand
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	CoordKillCommand
class	CoordKillXCommand
class	CoordMaterializeTransitionXCommand Materialize actions for specified start and end time for coordinator job.
class	CoordPauseXCommand
class	CoordPurgeCommand
class	CoordPurgeXCommand This class is used for coordinator purge command
class	CoordRecoveryCommand
class	CoordRerunCommand
class	CoordRerunXCommand Rerun coordinator actions by a list of dates or ids.
class	CoordResumeCommand
class	CoordResumeXCommand Resume coordinator job and actions.
class	CoordSubmitCommand This class provides the functionalities to resolve a coordinator job XML and write the job information into a DB table.
class	CoordSubmitXCommand This class provides the functionalities to resolve a coordinator job XML and write the job information into a DB table.
class	CoordSuspendCommand
class	CoordSuspendXCommand Suspend coordinator job and actions.
class	CoordUnpauseXCommand
class	SLAEventsCommand
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	ActionCheckCommand Executes the check command for ActionHandlers.
class	ActionCheckXCommand Executes the check command for ActionHandlers.
class	ActionCommand<T> Base class for Action execution commands.
class	ActionEndCommand
class	ActionEndXCommand
class	ActionKillCommand
class	ActionKillXCommand Kill workflow action and invoke action executor to kill the underlying context.
class	ActionStartCommand
class	ActionStartXCommand
class	ActionXCommand<T> Base class for Action execution commands.
class	CompletedActionCommand
class	CompletedActionXCommand This command is executed once the Workflow command is finished.
class	DefinitionCommand
class	DefinitionXCommand
class	ExternalIdCommand
class	ExternalIdXCommand
class	JobCommand Command for loading a job information
class	JobsCommand Command for loading the Workflows according to the given filter information
class	JobsXCommand
class	JobXCommand This Xcommand is returning the workflow with action within the range.
class	KillCommand
class	KillXCommand Kill workflow job and its workflow instance and queue a WorkflowActionKillXCommand to kill the workflow actions.
class	NotificationCommand
class	NotificationXCommand
class	PurgeCommand
class	PurgeXCommand
class	ReRunCommand
class	ReRunXCommand This is a RerunXCommand which is used for rerunn.
class	ResumeCommand
class	ResumeXCommand
class	SignalCommand
class	SignalXCommand
class	StartCommand
class	StartXCommand Starting the command.
class	SubmitCommand
class	SubmitHttpCommand
class	SubmitHttpXCommand
class	SubmitMRCommand
class	SubmitMRXCommand
class	SubmitPigCommand
class	SubmitPigXCommand
class	SubmitXCommand
class	SuspendCommand
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	WorkflowActionInfoCommand
class	WorkflowActionInfoXCommand
class	WorkflowCommand<T>
class	WorkflowXCommand<T> Abstract coordinator command class derived from XCommand

Uses of XCallable in org.apache.oozie.service

Methods in org.apache.oozie.service with parameters of type XCallable

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.