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

All Superinterfaces:
Callable<T>
All Known Implementing Classes:
ActionCheckXCommand, ActionEndXCommand, ActionKillXCommand, ActionStartXCommand, ActionXCommand, BulkJobsXCommand, BundleJobChangeXCommand, BundleJobResumeXCommand, BundleJobSuspendXCommand, BundleJobsXCommand, BundleJobXCommand, BundleKillXCommand, BundlePauseXCommand, BundlePurgeXCommand, BundleRerunXCommand, BundleStartXCommand, BundleStatusUpdateXCommand, BundleSubmitXCommand, BundleUnpauseXCommand, Command, CompletedActionXCommand, CoordActionCheckXCommand, CoordActionInfoXCommand, CoordActionInputCheckXCommand, CoordActionMaterializeCommand, CoordActionNotificationXCommand, CoordActionReadyXCommand, CoordActionStartXCommand, CoordActionTimeOutXCommand, CoordActionUpdateXCommand, CoordChangeXCommand, CoordinatorCommand, CoordinatorXCommand, CoordJobsXCommand, CoordJobXCommand, CoordKillXCommand, CoordMaterializeTransitionXCommand, CoordPauseXCommand, CoordPurgeXCommand, CoordRerunXCommand, CoordResumeXCommand, CoordSubmitXCommand, CoordSuspendXCommand, CoordUnpauseXCommand, DefinitionXCommand, ExternalIdXCommand, JobsXCommand, JobXCommand, KillTransitionXCommand, KillXCommand, MaterializeTransitionXCommand, NotificationXCommand, PauseTransitionXCommand, PurgeXCommand, RerunTransitionXCommand, ReRunXCommand, ResumeTransitionXCommand, ResumeXCommand, SignalXCommand, SLAEventsXCommand, StartTransitionXCommand, StartXCommand, StatusUpdateXCommand, SubmitHttpXCommand, SubmitMRXCommand, SubmitPigXCommand, SubmitTransitionXCommand, SubmitXCommand, SuspendTransitionXCommand, SuspendXCommand, TransitionXCommand, UnpauseTransitionXCommand, WfEndXCommand, WorkflowActionInfoXCommand, 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 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


inInterruptMode

boolean inInterruptMode()
Returns:
the mode of execution. true if it is executed as an Interrupt, false otherwise


Copyright © 2013 Apache Software Foundation. All Rights Reserved.