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


Copyright © 2012 Apache Software Foundation. All Rights Reserved.