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 |
IgnoreTransitionXCommand<T> |
class |
KillTransitionXCommand<T>
This is transition Base commands for all the jobs.
|
class |
MaterializeTransitionXCommand
Transition command for materialize the job.
|
class |
NotificationXCommand |
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 |
SchemaCheckXCommand |
class |
SLAAlertsXCommand |
class |
StartTransitionXCommand
Transition command for start the job.
|
class |
StatusTransitXCommand
StatusTransitXCommand is super class for Status Transit Command, it defines layout for Status Transit Commands.
|
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.
|
Modifier and Type | Class and Description |
---|---|
class |
BulkBundleXCommand |
class |
BundleCoordSubmitXCommand |
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 |
BundleSLAAlertsDisableXCommand |
class |
BundleSLAAlertsEnableXCommand |
class |
BundleSLAAlertsXCommand |
class |
BundleSLAChangeXCommand |
class |
BundleStartXCommand
The command to start Bundle job
|
class |
BundleStatusTransitXCommand
BundleStatusTransitXCommand update job's status according to its child actions' status.
|
class |
BundleStatusUpdateXCommand
The command to update Bundle status
|
class |
BundleSubmitXCommand
This Command will submit the bundle.
|
class |
BundleUnpauseXCommand |
Modifier and Type | Class and Description |
---|---|
class |
BulkCoordXCommand |
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 |
CoordActionMissingDependenciesXCommand |
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 |
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 |
CoordSLAAlertsDisableXCommand |
class |
CoordSLAAlertsEnableXCommand |
class |
CoordSLAAlertsXCommand |
class |
CoordSLAChangeXCommand |
class |
CoordStatusTransitXCommand
CoordStatusTransitXCommand update coord job's status according to its child actions' status.
|
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 |
CoordWfActionInfoXCommand |
class |
SLAEventsXCommand
The command to get a list of SLAEvents which are greater than given seqId.
|
Modifier and Type | Class and Description |
---|---|
class |
SLACoordActionJobEventXCommand |
class |
SLACoordActionJobHistoryXCommand |
class |
SLAJobEventXCommand |
class |
SLAJobHistoryXCommand |
class |
SLAWorkflowActionJobEventXCommand |
class |
SLAWorkflowActionJobHistoryXCommand |
class |
SLAWorkflowJobEventXCommand |
class |
SLAWorkflowJobHistoryXCommand |
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 |
BulkWorkflowXCommand |
class |
CompletedActionXCommand
This command is executed once the Workflow command is finished.
|
class |
DefinitionXCommand |
class |
ExternalIdXCommand |
class |
ForkedActionStartXCommand |
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
ActionKillXCommand to kill the workflow
actions. |
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 |
WorkflowActionRetryInfoXCommand |
class |
WorkflowNotificationXCommand |
class |
WorkflowXCommand<T>
Abstract coordinator command class derived from XCommand
|
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
|
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.
|
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.
|
Constructor and Description |
---|
CallableWrapper(XCallable<E> callable,
long delay) |
Modifier and Type | Method and Description |
---|---|
XCallable<E> |
PriorityDelayQueue.QueueElement.getElement()
Return the element from the wrapper.
|
Constructor and Description |
---|
QueueElement(XCallable<E> element,
int priority,
long delay,
TimeUnit unit)
Create an Element wrapper.
|
Copyright © 2018 Apache Software Foundation. All rights reserved.