org.apache.oozie.util

Interface XCallable<T>

All Superinterfaces:

Callable<T>

All Known Implementing Classes:

ActionCheckXCommand, ActionEndXCommand, ActionKillXCommand, ActionStartXCommand, ActionXCommand, BulkBundleXCommand, BulkCoordXCommand, BulkJobsXCommand, BulkWorkflowXCommand, BundleCoordSubmitXCommand, BundleJobChangeXCommand, BundleJobResumeXCommand, BundleJobSuspendXCommand, BundleJobsXCommand, BundleJobXCommand, BundleKillXCommand, BundlePauseXCommand, BundleRerunXCommand, BundleSLAAlertsDisableXCommand, BundleSLAAlertsEnableXCommand, BundleSLAAlertsXCommand, BundleSLAChangeXCommand, BundleStartXCommand, BundleStatusTransitXCommand, BundleStatusUpdateXCommand, BundleSubmitXCommand, BundleUnpauseXCommand, CompletedActionXCommand, CoordActionCheckXCommand, CoordActionInfoXCommand, CoordActionInputCheckXCommand, CoordActionMissingDependenciesXCommand, CoordActionNotificationXCommand, CoordActionReadyXCommand, CoordActionsIgnoreXCommand, CoordActionsKillXCommand, CoordActionSkipXCommand, CoordActionStartXCommand, CoordActionTimeOutXCommand, CoordActionUpdatePushMissingDependency, CoordActionUpdateXCommand, CoordChangeXCommand, CoordinatorXCommand, CoordJobsXCommand, CoordJobXCommand, CoordKillXCommand, CoordMaterializeTransitionXCommand, CoordPauseXCommand, CoordPushDependencyCheckXCommand, CoordRerunXCommand, CoordResumeXCommand, CoordSLAAlertsDisableXCommand, CoordSLAAlertsEnableXCommand, CoordSLAAlertsXCommand, CoordSLAChangeXCommand, CoordStatusTransitXCommand, CoordSubmitXCommand, CoordSuspendXCommand, CoordUnpauseXCommand, CoordUpdateXCommand, CoordWfActionInfoXCommand, DefinitionXCommand, ExternalIdXCommand, ForkedActionStartXCommand, IgnoreTransitionXCommand, JobsXCommand, JobXCommand, KillTransitionXCommand, KillXCommand, MaterializeTransitionXCommand, NotificationXCommand, PauseTransitionXCommand, PurgeXCommand, RerunTransitionXCommand, ReRunXCommand, ResumeTransitionXCommand, ResumeXCommand, SchemaCheckXCommand, SignalXCommand, SLAAlertsXCommand, SLACoordActionJobEventXCommand, SLACoordActionJobHistoryXCommand, SLAEventsXCommand, SLAJobEventXCommand, SLAJobHistoryXCommand, SLAWorkflowActionJobEventXCommand, SLAWorkflowActionJobHistoryXCommand, SLAWorkflowJobEventXCommand, SLAWorkflowJobHistoryXCommand, StartTransitionXCommand, StartXCommand, StatusTransitXCommand, StatusUpdateXCommand, SubmitHiveXCommand, SubmitHttpXCommand, SubmitMRXCommand, SubmitPigXCommand, SubmitScriptLanguageXCommand, SubmitSqoopXCommand, SubmitTransitionXCommand, SubmitXCommand, SuspendTransitionXCommand, SuspendXCommand, TransitionXCommand, UnpauseTransitionXCommand, WfEndXCommand, WorkflowActionInfoXCommand, WorkflowActionRetryInfoXCommand, WorkflowNotificationXCommand, WorkflowXCommand, XCommand

public interface XCallable<T>
extends Callable<T>

Extends Callable adding the concept of priority.

The priority is useful when queuing callables for later execution via the CallableQueueService.

A higher number means a higher priority.

Method Summary

Modifier and Type	Method and Description
long	getCreatedTime() Returns the createdTime of the callable in milliseconds
String	getEntityKey() Return the lock key of the callable
String	getKey() Return the key of the callable
String	getName() Return the callable name.
int	getPriority() Return the priority of the callable.
String	getType() Return the callable type.
boolean	inInterruptMode()
void	setInterruptMode(boolean mode) set the mode of execution for the callable.

Methods inherited from interface java.util.concurrent.Callable

call

Method Detail

getName

String getName()

Return the callable name.

Returns:

the callable name.

getPriority

int getPriority()

Return the priority of the callable.

Returns:

the callable priority.

getType

String getType()

Return the callable type.

The callable type is used for concurrency throttling in the CallableQueueService.

Returns:

the callable type.

getCreatedTime

long getCreatedTime()

Returns the createdTime of the callable in milliseconds

Returns:

the callable createdTime

getKey

String getKey()

Return the key of the callable

Returns:

the callable key

getEntityKey

String getEntityKey()

Return the lock key of the callable

Returns:

the callable Lock key

setInterruptMode

void setInterruptMode(boolean mode)

set the mode of execution for the callable. True if in interrupt, false if not

Parameters:

mode - the mode to set

inInterruptMode

boolean inInterruptMode()

Returns:

the mode of execution. true if it is executed as an Interrupt, false otherwise