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

Packages that use XCallable

Package	Description
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

Modifier and Type	Class and Description
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	IgnoreTransitionXCommand<T>
class	KillTransitionXCommand<T> 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	PurgeXCommand This class is used to purge workflows, coordinators, and bundles.
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Class and Description
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	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

Modifier and Type	Class and Description
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	CoordActionsIgnoreXCommand
class	CoordActionsKillXCommand Kill coordinator actions by a range of dates (nominal time) or action number.
class	CoordActionSkipXCommand This class sets a Coordinator action's status to SKIPPED
class	CoordActionStartXCommand
class	CoordActionTimeOutXCommand This class updates the Time out in the action bean
class	CoordActionUpdatePushMissingDependency
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	CoordPushDependencyCheckXCommand
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	CoordUpdateXCommand This class provides the functionalities to update coordinator job XML and properties.
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

Modifier and Type	Class and Description
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	ReRunXCommand This is a RerunXCommand which is used for rerunn.
class	ResumeXCommand
class	SignalXCommand
class	StartXCommand Starting the command.
class	SubmitHiveXCommand
class	SubmitHttpXCommand
class	SubmitMRXCommand
class	SubmitPigXCommand
class	SubmitScriptLanguageXCommand
class	SubmitSqoopXCommand
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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.