Package | Description |
---|---|
org.apache.oozie.command | |
org.apache.oozie.command.bundle | |
org.apache.oozie.command.coord | |
org.apache.oozie.command.sla | |
org.apache.oozie.command.wf |
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.
|
Modifier and Type | Method and Description |
---|---|
protected void |
XCommand.queue(XCommand<?> command)
Queue a command for execution after the current command execution completes.
|
protected void |
XCommand.queue(XCommand<?> command,
long msDelay)
Queue a command for delayed execution after the current command execution completes.
|
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 |
---|---|
protected void |
ForkedActionStartXCommand.queue(XCommand<?> command,
long msDelay) |
protected void |
ActionStartXCommand.queue(XCommand<?> command,
long msDelay) |
Copyright © 2018 Apache Software Foundation. All rights reserved.