This project has retired. For details please refer to its Attic page.

org.apache.oozie.util
Interface XCallable<T>

All Superinterfaces:

Callable<T>

All Known Implementing Classes:

ActionCheckCommand, ActionCheckXCommand, ActionCommand, ActionEndCommand, ActionEndXCommand, ActionKillCommand, ActionKillXCommand, ActionStartCommand, ActionStartXCommand, ActionXCommand, BundleJobChangeXCommand, BundleJobResumeXCommand, BundleJobSuspendXCommand, BundleJobsXCommand, BundleJobXCommand, BundleKillXCommand, BundlePauseXCommand, BundlePurgeXCommand, BundleRerunXCommand, BundleStartXCommand, BundleStatusUpdateXCommand, BundleSubmitXCommand, BundleUnpauseXCommand, Command, CompletedActionCommand, CompletedActionXCommand, CoordActionCheckCommand, CoordActionCheckXCommand, CoordActionInfoCommand, CoordActionInfoXCommand, CoordActionInputCheckCommand, CoordActionInputCheckXCommand, CoordActionMaterializeCommand, CoordActionNotification, CoordActionNotificationXCommand, CoordActionReadyCommand, CoordActionReadyXCommand, CoordActionStartCommand, CoordActionStartXCommand, CoordActionTimeOut, CoordActionTimeOutXCommand, CoordActionUpdateCommand, CoordActionUpdateXCommand, CoordChangeCommand, CoordChangeXCommand, CoordinatorCommand, CoordinatorXCommand, CoordJobCommand, CoordJobMatLookupCommand, CoordJobsCommand, CoordJobsXCommand, CoordJobXCommand, CoordKillCommand, CoordKillXCommand, CoordMaterializeTransitionXCommand, CoordPauseXCommand, CoordPurgeCommand, CoordPurgeXCommand, CoordRecoveryCommand, CoordRerunCommand, CoordRerunXCommand, CoordResumeCommand, CoordResumeXCommand, CoordSubmitCommand, CoordSubmitXCommand, CoordSuspendCommand, CoordSuspendXCommand, CoordUnpauseXCommand, DefinitionCommand, DefinitionXCommand, ExternalIdCommand, ExternalIdXCommand, JobCommand, JobsCommand, JobsXCommand, JobXCommand, KillCommand, KillTransitionXCommand, KillXCommand, MaterializeTransitionXCommand, NotificationCommand, NotificationXCommand, PauseTransitionXCommand, PurgeCommand, PurgeXCommand, ReRunCommand, RerunTransitionXCommand, ReRunXCommand, ResumeCommand, ResumeTransitionXCommand, ResumeXCommand, SignalCommand, SignalXCommand, SLAEventsCommand, SLAEventsXCommand, StartCommand, StartTransitionXCommand, StartXCommand, StatusUpdateXCommand, SubmitCommand, SubmitHttpCommand, SubmitHttpXCommand, SubmitMRCommand, SubmitMRXCommand, SubmitPigCommand, SubmitPigXCommand, SubmitTransitionXCommand, SubmitXCommand, SuspendCommand, SuspendTransitionXCommand, SuspendXCommand, TransitionXCommand, UnpauseTransitionXCommand, WfEndXCommand, WorkflowActionInfoCommand, WorkflowActionInfoXCommand, WorkflowCommand, 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

long	getCreatedTime() Returns the createdTime of the callable in milliseconds
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.

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