Modifier and Type | Method and Description |
---|---|
List<Pair<CoordinatorActionBean,Map<String,ActionDependency>>> |
CoordinatorEngine.getCoordActionMissingDependencies(String id,
String actions,
String dates)
Get coord action missing dependencies
|
void |
CoordinatorEngine.streamLog(String jobId,
String logRetrievalScope,
String logRetrievalType,
Writer writer,
Map<String,String[]> requestParameters)
Add list of actions to the filter based on conditions
|
Modifier and Type | Method and Description |
---|---|
T |
XCommand.call()
Implements the XCommand life-cycle.
|
protected void |
XCommand.eagerLoadState()
Load the necessary state to perform an eager precondition check.
|
protected void |
RerunTransitionXCommand.eagerLoadState() |
protected void |
XCommand.eagerVerifyPrecondition()
Verify the precondition for the command before obtaining a lock.
|
protected void |
RerunTransitionXCommand.eagerVerifyPrecondition() |
protected abstract T |
XCommand.execute()
Command execution body.
|
protected Void |
UnpauseTransitionXCommand.execute() |
protected T |
TransitionXCommand.execute() |
protected Void |
SuspendTransitionXCommand.execute() |
protected String |
SubmitTransitionXCommand.execute() |
protected Void |
StatusTransitXCommand.execute() |
protected Void |
StartTransitionXCommand.execute() |
protected Void |
SLAAlertsXCommand.execute() |
protected Void |
SchemaCheckXCommand.execute() |
protected Void |
ResumeTransitionXCommand.execute() |
protected T |
RerunTransitionXCommand.execute() |
protected Void |
PurgeXCommand.execute() |
protected Void |
PauseTransitionXCommand.execute() |
protected Void |
NotificationXCommand.execute() |
protected Void |
MaterializeTransitionXCommand.execute() |
protected T |
KillTransitionXCommand.execute() |
protected T |
IgnoreTransitionXCommand.execute() |
protected BulkResponseInfo |
BulkJobsXCommand.execute() |
protected abstract boolean |
SLAAlertsXCommand.executeSlaCommand()
Execute sla command.
|
void |
TransitionXCommand.generateEvents(CoordinatorJobBean coordJob,
Date startTime)
This will be used to generate Job Notification events on status changes
|
protected Job.Status |
StatusTransitXCommand.getJobStatus()
Gets the job status.
|
abstract void |
IgnoreTransitionXCommand.ignoreChildren() |
protected abstract boolean |
SLAAlertsXCommand.isJobRequest() |
abstract void |
KillTransitionXCommand.killChildren() |
protected abstract void |
XCommand.loadState()
Load the necessary state to perform the precondition check and to execute the command.
|
protected void |
SLAAlertsXCommand.loadState() |
protected void |
SchemaCheckXCommand.loadState() |
protected void |
PurgeXCommand.loadState() |
protected void |
BulkJobsXCommand.loadState() |
protected abstract void |
MaterializeTransitionXCommand.materialize()
Materialize the actions for current job
|
abstract void |
TransitionXCommand.notifyParent()
This will be used to notify the parent about the status of that perticular job.
|
abstract void |
PauseTransitionXCommand.pauseChildren()
pause actions associated with the job
|
abstract void |
TransitionXCommand.performWrites()
This will be used to perform atomically all the writes within this command.
|
abstract void |
RerunTransitionXCommand.rerunChildren()
Rerun actions associated with the job
|
abstract void |
ResumeTransitionXCommand.resumeChildren()
Resume all children of the job
|
abstract void |
StartTransitionXCommand.StartChildren()
Start actions associated with the job
|
protected abstract String |
SubmitTransitionXCommand.submit()
Submit the job
|
abstract void |
SuspendTransitionXCommand.suspendChildren()
Suspend all children of the job
|
void |
UnpauseTransitionXCommand.transitToNext() |
abstract void |
TransitionXCommand.transitToNext()
Transit to the next status based on the result of the Job.
|
void |
PauseTransitionXCommand.transitToNext() |
void |
MaterializeTransitionXCommand.transitToNext() |
void |
IgnoreTransitionXCommand.transitToNext() |
abstract void |
UnpauseTransitionXCommand.unpauseChildren()
Unpause actions associated with the job
|
abstract void |
TransitionXCommand.updateJob()
Update the parent job.
|
protected abstract void |
SLAAlertsXCommand.updateJob()
Update job.
|
protected abstract void |
StatusTransitXCommand.updateJobStatus(Job.Status status)
Update job status.
|
protected void |
SLAAlertsXCommand.validateSLAChangeParam(Map<String,String> slaParams) |
protected abstract void |
XCommand.verifyPrecondition()
Verify the precondition for the command after a lock has been obtain, just before executing the command.
|
protected void |
SLAAlertsXCommand.verifyPrecondition() |
protected void |
SchemaCheckXCommand.verifyPrecondition() |
protected void |
RerunTransitionXCommand.verifyPrecondition() |
protected void |
PurgeXCommand.verifyPrecondition() |
protected void |
NotificationXCommand.verifyPrecondition() |
protected void |
BulkJobsXCommand.verifyPrecondition() |
Modifier and Type | Method and Description |
---|---|
protected void |
BundleSubmitXCommand.eagerLoadState() |
protected void |
BundleJobChangeXCommand.eagerLoadState() |
protected void |
BundleSubmitXCommand.eagerVerifyPrecondition() |
protected void |
BundleJobChangeXCommand.eagerVerifyPrecondition() |
protected Void |
BundleStatusUpdateXCommand.execute() |
protected BundleJobBean |
BundleJobXCommand.execute() |
protected BundleJobInfo |
BundleJobsXCommand.execute() |
protected Void |
BundleJobChangeXCommand.execute() |
protected BundleJobInfo |
BulkBundleXCommand.execute() |
protected void |
BundleSLAChangeXCommand.executeCoordCommand(String id,
String actions,
String dates) |
protected abstract void |
BundleSLAAlertsXCommand.executeCoordCommand(String id,
String actions,
String dates) |
protected void |
BundleSLAAlertsEnableXCommand.executeCoordCommand(String id,
String actions,
String dates) |
protected void |
BundleSLAAlertsDisableXCommand.executeCoordCommand(String id,
String actions,
String dates) |
protected boolean |
BundleSLAAlertsXCommand.executeSlaCommand() |
protected Set<String> |
BundleSLAAlertsXCommand.getCoordJobsFromBundle(String id,
String coords)
Gets the coord jobs from bundle.
|
protected Job.Status |
BundleStatusTransitXCommand.getJobStatus() |
void |
BundleKillXCommand.killChildren() |
void |
BundleUnpauseXCommand.loadState() |
protected void |
BundleSubmitXCommand.loadState() |
protected void |
BundleStatusUpdateXCommand.loadState() |
protected void |
BundleStatusTransitXCommand.loadState() |
void |
BundleStartXCommand.loadState() |
protected void |
BundleSLAChangeXCommand.loadState() |
protected void |
BundleSLAAlertsXCommand.loadState() |
protected void |
BundleSLAAlertsEnableXCommand.loadState() |
protected void |
BundleSLAAlertsDisableXCommand.loadState() |
protected void |
BundleRerunXCommand.loadState() |
void |
BundlePauseXCommand.loadState() |
void |
BundleKillXCommand.loadState() |
protected void |
BundleJobXCommand.loadState() |
protected void |
BundleJobsXCommand.loadState() |
protected void |
BundleJobSuspendXCommand.loadState() |
protected void |
BundleJobResumeXCommand.loadState() |
protected void |
BundleJobChangeXCommand.loadState() |
protected void |
BundleCoordSubmitXCommand.loadState() |
protected void |
BulkBundleXCommand.loadState() |
protected void |
BundleSubmitXCommand.mergeDefaultConfig()
Merge default configuration with user-defined configuration.
|
void |
BundleSubmitXCommand.notifyParent() |
void |
BundleRerunXCommand.notifyParent() |
void |
BundleJobSuspendXCommand.notifyParent() |
void |
BundleJobResumeXCommand.notifyParent() |
void |
BundlePauseXCommand.pauseChildren() |
void |
BundleUnpauseXCommand.performWrites() |
void |
BundleSubmitXCommand.performWrites() |
void |
BundleStartXCommand.performWrites() |
void |
BundleRerunXCommand.performWrites() |
void |
BundlePauseXCommand.performWrites() |
void |
BundleKillXCommand.performWrites() |
void |
BundleJobSuspendXCommand.performWrites() |
void |
BundleJobResumeXCommand.performWrites() |
void |
BundleRerunXCommand.rerunChildren() |
void |
BundleStartXCommand.StartChildren() |
protected String |
BundleSubmitXCommand.submit() |
void |
BundleJobSuspendXCommand.suspendChildren() |
void |
BundleUnpauseXCommand.unpauseChildren() |
void |
BundleUnpauseXCommand.updateJob() |
void |
BundleSubmitXCommand.updateJob() |
void |
BundleStartXCommand.updateJob() |
protected void |
BundleSLAChangeXCommand.updateJob() |
protected void |
BundleSLAAlertsEnableXCommand.updateJob() |
protected void |
BundleSLAAlertsDisableXCommand.updateJob() |
void |
BundlePauseXCommand.updateJob() |
protected void |
BundleUnpauseXCommand.verifyPrecondition() |
protected void |
BundleSubmitXCommand.verifyPrecondition() |
protected void |
BundleStatusUpdateXCommand.verifyPrecondition() |
protected void |
BundleStatusTransitXCommand.verifyPrecondition() |
protected void |
BundleStartXCommand.verifyPrecondition() |
protected void |
BundleSLAChangeXCommand.verifyPrecondition() |
protected void |
BundlePauseXCommand.verifyPrecondition() |
protected void |
BundleKillXCommand.verifyPrecondition() |
protected void |
BundleJobXCommand.verifyPrecondition() |
protected void |
BundleJobsXCommand.verifyPrecondition() |
protected void |
BundleJobSuspendXCommand.verifyPrecondition() |
protected void |
BundleJobResumeXCommand.verifyPrecondition() |
protected void |
BundleJobChangeXCommand.verifyPrecondition() |
protected void |
BundleCoordSubmitXCommand.verifyPrecondition() |
protected void |
BulkBundleXCommand.verifyPrecondition() |
Constructor and Description |
---|
BundleJobChangeXCommand(String id,
String changeValue) |
Modifier and Type | Method and Description |
---|---|
protected void |
CoordMaterializeTransitionXCommand.calcMatdTime()
Calculate startMatdTime and endMatdTime from job's start time if next materialized time is null
|
void |
CoordUpdateXCommand.check(CoordinatorJobBean oldCoord,
CoordinatorJobBean newCoord)
Check.
|
static void |
CoordCommandUtils.checkIfBothSameType(String startInst,
String endInst) |
protected void |
CoordRerunXCommand.eagerLoadState() |
protected void |
CoordRerunXCommand.eagerVerifyPrecondition() |
protected void |
CoordActionMissingDependenciesXCommand.eagerVerifyPrecondition() |
protected List<SLAEventBean> |
SLAEventsXCommand.execute() |
protected List<CoordinatorWfActionBean> |
CoordWfActionInfoXCommand.execute() |
protected Void |
CoordPushDependencyCheckXCommand.execute() |
protected CoordinatorJobBean |
CoordJobXCommand.execute() |
protected CoordinatorJobInfo |
CoordJobsXCommand.execute() |
protected Void |
CoordChangeXCommand.execute() |
protected Void |
CoordActionUpdateXCommand.execute() |
protected Void |
CoordActionUpdatePushMissingDependency.execute() |
protected Void |
CoordActionTimeOutXCommand.execute() |
protected Void |
CoordActionStartXCommand.execute() |
protected Void |
CoordActionSkipXCommand.execute() |
protected Void |
CoordActionReadyXCommand.execute() |
protected List<Pair<CoordinatorActionBean,Map<String,ActionDependency>>> |
CoordActionMissingDependenciesXCommand.execute() |
protected Void |
CoordActionInputCheckXCommand.execute() |
protected CoordinatorActionBean |
CoordActionInfoXCommand.execute() |
protected Void |
CoordActionCheckXCommand.execute() |
protected CoordinatorJobInfo |
BulkCoordXCommand.execute() |
protected boolean |
CoordSLAChangeXCommand.executeSlaCommand() |
protected boolean |
CoordSLAAlertsEnableXCommand.executeSlaCommand() |
protected boolean |
CoordSLAAlertsDisableXCommand.executeSlaCommand() |
protected XConfiguration |
CoordSLAAlertsXCommand.getJobConf() |
protected Job.Status |
CoordStatusTransitXCommand.getJobStatus() |
void |
CoordActionsIgnoreXCommand.ignoreChildren() |
void |
CoordKillXCommand.killChildren() |
void |
CoordActionsKillXCommand.killChildren() |
protected void |
SLAEventsXCommand.loadState() |
protected void |
CoordWfActionInfoXCommand.loadState()
(non-Javadoc)
|
protected void |
CoordUpdateXCommand.loadState() |
void |
CoordUnpauseXCommand.loadState() |
protected void |
CoordSuspendXCommand.loadState() |
protected void |
CoordSubmitXCommand.loadState() |
protected void |
CoordStatusTransitXCommand.loadState() |
protected void |
CoordSLAAlertsXCommand.loadState() |
protected void |
CoordResumeXCommand.loadState() |
protected void |
CoordRerunXCommand.loadState() |
protected void |
CoordPushDependencyCheckXCommand.loadState() |
void |
CoordPauseXCommand.loadState() |
protected void |
CoordMaterializeTransitionXCommand.loadState() |
protected void |
CoordKillXCommand.loadState() |
protected void |
CoordJobXCommand.loadState() |
protected void |
CoordJobsXCommand.loadState() |
protected void |
CoordChangeXCommand.loadState() |
protected void |
CoordActionUpdateXCommand.loadState() |
protected void |
CoordActionTimeOutXCommand.loadState() |
protected void |
CoordActionStartXCommand.loadState() |
protected void |
CoordActionSkipXCommand.loadState() |
protected void |
CoordActionsKillXCommand.loadState() |
protected void |
CoordActionsIgnoreXCommand.loadState() |
protected void |
CoordActionReadyXCommand.loadState() |
protected void |
CoordActionNotificationXCommand.loadState() |
protected void |
CoordActionMissingDependenciesXCommand.loadState() |
protected void |
CoordActionInputCheckXCommand.loadState() |
protected void |
CoordActionInfoXCommand.loadState() |
protected void |
CoordActionCheckXCommand.loadState() |
protected void |
BulkCoordXCommand.loadState() |
protected void |
CoordMaterializeTransitionXCommand.materialize() |
protected void |
CoordSubmitXCommand.mergeDefaultConfig()
Merge default configuration with user-defined configuration.
|
void |
CoordUpdateXCommand.notifyParent() |
void |
CoordUnpauseXCommand.notifyParent() |
void |
CoordSuspendXCommand.notifyParent() |
void |
CoordSubmitXCommand.notifyParent() |
void |
CoordResumeXCommand.notifyParent() |
void |
CoordRerunXCommand.notifyParent() |
void |
CoordPauseXCommand.notifyParent() |
void |
CoordMaterializeTransitionXCommand.notifyParent() |
void |
CoordKillXCommand.notifyParent() |
void |
CoordActionsKillXCommand.notifyParent() |
protected void |
CoordPushDependencyCheckXCommand.onAllPushDependenciesAvailable(boolean isPullDependencyMeet) |
void |
CoordPauseXCommand.pauseChildren() |
void |
CoordUnpauseXCommand.performWrites() |
void |
CoordSuspendXCommand.performWrites() |
void |
CoordSubmitXCommand.performWrites() |
void |
CoordResumeXCommand.performWrites() |
void |
CoordRerunXCommand.performWrites() |
void |
CoordPauseXCommand.performWrites() |
void |
CoordMaterializeTransitionXCommand.performWrites() |
void |
CoordKillXCommand.performWrites() |
void |
CoordActionsKillXCommand.performWrites() |
void |
CoordActionsIgnoreXCommand.performWrites() |
void |
CoordRerunXCommand.rerunChildren() |
void |
CoordResumeXCommand.resumeChildren() |
protected String |
CoordUpdateXCommand.storeToDB(String xmlElement,
org.jdom.Element eJob,
CoordinatorJobBean coordJob) |
protected String |
CoordSubmitXCommand.storeToDB(String appXML,
org.jdom.Element eJob,
CoordinatorJobBean coordJob)
Write a coordinator job into database
|
protected String |
CoordUpdateXCommand.submit() |
protected String |
CoordSubmitXCommand.submit() |
protected String |
CoordSubmitXCommand.submitJob() |
void |
CoordSuspendXCommand.suspendChildren() |
void |
CoordMaterializeTransitionXCommand.transitToNext() |
void |
CoordUnpauseXCommand.unpauseChildren() |
protected void |
CoordPushDependencyCheckXCommand.updateCoordAction(CoordinatorActionBean coordAction,
boolean isChangeInDependency) |
void |
CoordUnpauseXCommand.updateJob() |
void |
CoordSubmitXCommand.updateJob() |
protected void |
CoordSLAChangeXCommand.updateJob() |
protected void |
CoordSLAAlertsEnableXCommand.updateJob() |
protected void |
CoordSLAAlertsDisableXCommand.updateJob() |
void |
CoordPauseXCommand.updateJob() |
void |
CoordMaterializeTransitionXCommand.updateJob() |
void |
CoordKillXCommand.updateJob() |
void |
CoordActionsKillXCommand.updateJob() |
protected void |
CoordSLAAlertsXCommand.updateJobConf(org.apache.hadoop.conf.Configuration newConf)
Update job conf.
|
protected void |
CoordSLAAlertsXCommand.updateJobSLA(Map<String,String> newParams)
Update job sla.
|
protected void |
CoordStatusTransitXCommand.updateJobStatus(Job.Status coordStatus) |
protected void |
SLAEventsXCommand.verifyPrecondition() |
protected void |
CoordWfActionInfoXCommand.verifyPrecondition()
(non-Javadoc)
|
protected void |
CoordUpdateXCommand.verifyPrecondition() |
protected void |
CoordUnpauseXCommand.verifyPrecondition() |
protected void |
CoordSuspendXCommand.verifyPrecondition() |
protected void |
CoordSubmitXCommand.verifyPrecondition() |
protected void |
CoordStatusTransitXCommand.verifyPrecondition() |
protected void |
CoordSLAChangeXCommand.verifyPrecondition() |
protected void |
CoordResumeXCommand.verifyPrecondition() |
protected void |
CoordRerunXCommand.verifyPrecondition() |
protected void |
CoordPushDependencyCheckXCommand.verifyPrecondition() |
protected void |
CoordPauseXCommand.verifyPrecondition() |
protected void |
CoordMaterializeTransitionXCommand.verifyPrecondition() |
protected void |
CoordKillXCommand.verifyPrecondition() |
protected void |
CoordJobXCommand.verifyPrecondition() |
protected void |
CoordJobsXCommand.verifyPrecondition() |
protected void |
CoordChangeXCommand.verifyPrecondition() |
protected void |
CoordActionUpdateXCommand.verifyPrecondition() |
protected void |
CoordActionTimeOutXCommand.verifyPrecondition() |
protected void |
CoordActionSkipXCommand.verifyPrecondition() |
protected void |
CoordActionsKillXCommand.verifyPrecondition() |
protected void |
CoordActionsIgnoreXCommand.verifyPrecondition() |
protected void |
CoordActionReadyXCommand.verifyPrecondition() |
protected void |
CoordActionMissingDependenciesXCommand.verifyPrecondition() |
protected void |
CoordActionInputCheckXCommand.verifyPrecondition() |
protected void |
CoordActionInfoXCommand.verifyPrecondition() |
protected void |
CoordActionCheckXCommand.verifyPrecondition() |
protected void |
BulkCoordXCommand.verifyPrecondition() |
Constructor and Description |
---|
CoordChangeXCommand(String id,
String changeValue)
This command is used to update the Coordinator job with the new values Update the coordinator job bean and update
that to database.
|
Modifier and Type | Method and Description |
---|---|
protected Boolean |
SLAJobHistoryXCommand.execute() |
protected Void |
SLAJobEventXCommand.execute() |
protected void |
SLAWorkflowJobHistoryXCommand.loadState() |
protected void |
SLAWorkflowJobEventXCommand.loadState() |
protected void |
SLAWorkflowActionJobHistoryXCommand.loadState() |
protected void |
SLAWorkflowActionJobEventXCommand.loadState() |
protected void |
SLACoordActionJobHistoryXCommand.loadState() |
protected void |
SLACoordActionJobEventXCommand.loadState() |
protected abstract void |
SLAJobHistoryXCommand.updateSLASummary()
Update SLASummary
|
protected void |
SLACoordActionJobHistoryXCommand.updateSLASummary() |
protected void |
SLAJobHistoryXCommand.verifyPrecondition() |
protected void |
SLAJobEventXCommand.verifyPrecondition() |
Modifier and Type | Method and Description |
---|---|
protected void |
ActionStartXCommand.callActionEnd() |
protected void |
SuspendXCommand.eagerLoadState() |
protected void |
ReRunXCommand.eagerLoadState()
Loading the Wfjob and workflow actions.
|
protected void |
CompletedActionXCommand.eagerLoadState() |
protected void |
ActionCheckXCommand.eagerLoadState() |
protected void |
SuspendXCommand.eagerVerifyPrecondition() |
protected void |
ReRunXCommand.eagerVerifyPrecondition()
Checks the pre-conditions that are required for workflow to recover - Last run of Workflow should be completed -
The nodes that are to be skipped are to be completed successfully in the base run.
|
protected void |
CompletedActionXCommand.eagerVerifyPrecondition() |
protected void |
ActionCheckXCommand.eagerVerifyPrecondition() |
protected void |
ActionStartXCommand.endWF() |
protected List<Map<String,String>> |
WorkflowActionRetryInfoXCommand.execute() |
protected WorkflowActionBean |
WorkflowActionInfoXCommand.execute() |
protected Void |
WfEndXCommand.execute() |
protected Void |
SuspendXCommand.execute() |
protected String |
SubmitXCommand.execute() |
protected String |
SubmitHttpXCommand.execute() |
protected Void |
SignalXCommand.execute() |
protected Void |
ResumeXCommand.execute() |
protected Void |
ReRunXCommand.execute() |
protected Void |
KillXCommand.execute() |
protected WorkflowJobBean |
JobXCommand.execute() |
protected WorkflowsInfo |
JobsXCommand.execute() |
protected ActionXCommand.ActionExecutorContext |
ForkedActionStartXCommand.execute() |
protected String |
ExternalIdXCommand.execute() |
protected String |
DefinitionXCommand.execute() |
protected Void |
CompletedActionXCommand.execute() |
protected WorkflowsInfo |
BulkWorkflowXCommand.execute() |
protected ActionXCommand.ActionExecutorContext |
ActionStartXCommand.execute() |
protected Void |
ActionKillXCommand.execute() |
protected Void |
ActionEndXCommand.execute() |
protected Void |
ActionCheckXCommand.execute() |
void |
ActionXCommand.failJob(ActionExecutor.Context context)
Fail the job due to failed action
|
void |
ForkedActionStartXCommand.failJob(ActionExecutor.Context context,
WorkflowActionBean action) |
void |
ActionXCommand.failJob(ActionExecutor.Context context,
WorkflowActionBean action)
Fail the job due to failed action
|
protected void |
ActionXCommand.handleError(ActionExecutor.Context context,
ActionExecutor executor,
String message,
boolean isStart,
WorkflowAction.Status status)
Takes care of errors.
|
protected void |
ForkedActionStartXCommand.handleError(ActionXCommand.ActionExecutorContext context,
WorkflowJobBean workflow,
WorkflowActionBean action) |
protected void |
ActionStartXCommand.handleError(ActionXCommand.ActionExecutorContext context,
WorkflowJobBean workflow,
WorkflowActionBean action) |
protected void |
ForkedActionStartXCommand.handleNonTransient(ActionExecutor.Context context,
ActionExecutor executor,
WorkflowAction.Status status) |
protected void |
ActionXCommand.handleNonTransient(ActionExecutor.Context context,
ActionExecutor executor,
WorkflowAction.Status status)
Takes care of non transient failures.
|
protected boolean |
ActionXCommand.handleTransient(ActionExecutor.Context context,
ActionExecutor executor,
WorkflowAction.Status status)
Takes care of Transient failures.
|
boolean |
ActionXCommand.handleUserRetry(ActionExecutor.Context context,
WorkflowActionBean action)
Execute retry for action if this action is eligible for user-retry
|
protected void |
WorkflowNotificationXCommand.loadState() |
protected void |
WorkflowActionRetryInfoXCommand.loadState() |
protected void |
WfEndXCommand.loadState() |
protected void |
SuspendXCommand.loadState() |
protected void |
SignalXCommand.loadState() |
protected void |
ResumeXCommand.loadState() |
protected void |
ReRunXCommand.loadState() |
protected void |
KillXCommand.loadState() |
protected void |
JobXCommand.loadState() |
protected void |
JobsXCommand.loadState() |
protected void |
ExternalIdXCommand.loadState() |
protected void |
DefinitionXCommand.loadState() |
protected void |
CompletedActionXCommand.loadState() |
protected void |
BulkWorkflowXCommand.loadState() |
protected void |
ActionStartXCommand.loadState() |
protected void |
ActionKillXCommand.loadState() |
protected void |
ActionEndXCommand.loadState() |
protected void |
ActionCheckXCommand.loadState() |
static String |
SubmitXCommand.resolveSla(org.jdom.Element eSla,
ELEvaluator evalSla)
Resolve variables in sla xml element.
|
void |
SignalXCommand.startForkedActions(List<WorkflowActionBean> workflowActionBeanListForForked) |
void |
SignalXCommand.startForkedActionsByQueuing(List<WorkflowActionBean> workflowActionBeanListForForked) |
static void |
SuspendXCommand.suspendJob(JPAService jpaService,
WorkflowJobBean workflow,
String id,
String actionId,
List<BatchQueryExecutor.UpdateEntry> updateList)
Suspend the workflow job and pending flag to false for the actions that are START_RETRY or START_MANUAL or
END_RETRY or END_MANUAL
|
protected void |
WorkflowXCommand.updateParentIfNecessary(WorkflowJobBean wfjob) |
protected void |
WorkflowXCommand.updateParentIfNecessary(WorkflowJobBean wfjob,
int maxRetries) |
protected void |
ForkedActionStartXCommand.updateParentIfNecessary(WorkflowJobBean wfjob,
int maxRetries) |
protected void |
WorkflowActionRetryInfoXCommand.verifyPrecondition() |
protected void |
WorkflowActionInfoXCommand.verifyPrecondition() |
protected void |
WfEndXCommand.verifyPrecondition() |
protected void |
SuspendXCommand.verifyPrecondition() |
protected void |
SubmitXCommand.verifyPrecondition() |
protected void |
SubmitSqoopXCommand.verifyPrecondition() |
protected void |
SubmitScriptLanguageXCommand.verifyPrecondition() |
protected void |
SubmitMRXCommand.verifyPrecondition() |
protected void |
SignalXCommand.verifyPrecondition() |
protected void |
ResumeXCommand.verifyPrecondition() |
protected void |
ReRunXCommand.verifyPrecondition() |
protected void |
KillXCommand.verifyPrecondition() |
protected void |
JobXCommand.verifyPrecondition() |
protected void |
JobsXCommand.verifyPrecondition() |
protected void |
ExternalIdXCommand.verifyPrecondition() |
protected void |
DefinitionXCommand.verifyPrecondition() |
protected void |
CompletedActionXCommand.verifyPrecondition() |
protected void |
BulkWorkflowXCommand.verifyPrecondition() |
protected void |
ActionStartXCommand.verifyPrecondition() |
protected void |
ActionKillXCommand.verifyPrecondition() |
protected void |
ActionEndXCommand.verifyPrecondition() |
protected void |
ActionCheckXCommand.verifyPrecondition() |
Modifier and Type | Method and Description |
---|---|
static List<String> |
CoordUtils.getActionListForScopeAndDate(String id,
String scope,
String dates) |
static Set<String> |
CoordUtils.getActionsIds(String jobId,
String scope) |
static List<CoordinatorActionBean> |
CoordUtils.getCoordActions(String rangeType,
String jobId,
String scope,
boolean active)
Get the list of actions for a given coordinator job
|
static List<CoordinatorActionBean> |
CoordUtils.getCoordActionsFromDates(String jobId,
String scope,
boolean active)
Get the list of actions for given date ranges
|
static List<CoordinatorActionBean> |
CoordUtils.getCoordActionsFromIds(String jobId,
String scope)
Get the list of actions for given id ranges
|
Modifier and Type | Method and Description |
---|---|
ActionDependency |
CoordOldInputDependency.checkPushMissingDependencies(CoordinatorActionBean coordAction,
boolean registerForNotification) |
ActionDependency |
CoordInputDependency.checkPushMissingDependencies(CoordinatorActionBean coordAction,
boolean registerForNotification)
Check push missing dependencies.
|
ActionDependency |
AbstractCoordInputDependency.checkPushMissingDependencies(CoordinatorActionBean coordAction,
boolean registerForNotification) |
Map<String,ActionDependency> |
CoordPullInputDependency.getMissingDependencies(CoordinatorActionBean coordAction) |
Map<String,ActionDependency> |
CoordOldInputDependency.getMissingDependencies(CoordinatorActionBean coordAction) |
Map<String,ActionDependency> |
CoordInputDependency.getMissingDependencies(CoordinatorActionBean coordAction)
Gets the missing dependencies.
|
Map<String,ActionDependency> |
AbstractCoordInputDependency.getMissingDependencies(CoordinatorActionBean coordAction) |
Modifier and Type | Method and Description |
---|---|
void |
CoordInputLogicEvaluatorUtil.validateInputLogic()
Validate input logic.
|
Modifier and Type | Method and Description |
---|---|
static ActionDependency |
DependencyChecker.checkForAvailability(List<String> missingDependencies,
org.apache.hadoop.conf.Configuration actionConf,
boolean stopOnFirstMissing)
Get the currently missing and available dependencies after checking the list of known missing
dependencies against the source.
|
static ActionDependency |
DependencyChecker.checkForAvailability(String missingDependencies,
org.apache.hadoop.conf.Configuration actionConf,
boolean stopOnFirstMissing)
Get the currently missing and available dependencies after checking the list of known missing
dependencies against the source.
|
Modifier and Type | Method and Description |
---|---|
static SLARegistrationBean |
SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla,
String jobId,
AppType appType,
String user,
String appName,
XLog log) |
static SLARegistrationBean |
SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla,
String jobId,
AppType appType,
String user,
XLog log) |
static SLARegistrationBean |
SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla,
String jobId,
String parentId,
AppType appType,
String user,
String appName,
XLog log,
boolean rerun) |
static SLARegistrationBean |
SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla,
String jobId,
String parentId,
AppType appType,
String user,
String appName,
XLog log,
boolean rerun,
boolean disableAlert) |
static SLARegistrationBean |
SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla,
String jobId,
String parentId,
AppType appType,
String user,
XLog log) |
static void |
SLAOperations.setExpectedEnd(String strExpectedEnd,
Date nominalTime,
SLARegistrationBean sla) |
static void |
SLAOperations.setExpectedStart(String strExpectedStart,
Date nominalTime,
SLARegistrationBean sla) |
static Date |
SLAOperations.setNominalTime(String strNominalTime,
SLARegistrationBean sla) |
static void |
SLAOperations.updateRegistrationEvent(String jobId)
Retrieve registration event
|
Modifier and Type | Method and Description |
---|---|
static void |
PropertiesUtils.checkDisallowedProperties(org.apache.hadoop.conf.Configuration conf,
Set<String> set)
Validate against DISALLOWED Properties.
|
static Date |
CoordActionsInDateRange.getCoordActionsLastModifiedDate(String jobId,
String startAction,
String endAction)
Gets the coordinator actions last modified date for range, if any action is running it return new date
|
static Map<String,String> |
JobUtils.parseChangeValue(String changeValue)
This Function will parse the value of the changed values in key value manner.
|
void |
XLogUserFilterParam.validateLogLevel(String loglevel)
Validate log level.
|
void |
XLogUserFilterParam.validateSearchText()
Validate search text.
|
Constructor and Description |
---|
XLogAuditStreamer(Map<String,String[]> requestParameters) |
XLogErrorStreamer(Map<String,String[]> requestParameters) |
XLogStreamer(Map<String,String[]> params) |
XLogUserFilterParam(Map<String,String[]> params)
Instantiates a new log user param.
|
Modifier and Type | Method and Description |
---|---|
static SLAEventBean |
SLADbXOperations.createStatusEvent(String slaXml,
String id,
SLAEvent.Status stat,
SLAEvent.SlaAppType appType)
Deprecated.
Create SLA status event
|
static SLAEventBean |
SLADbOperations.createStatusEvent(String slaXml,
String id,
SLAEvent.Status stat,
SLAEvent.SlaAppType appType,
XLog log)
Deprecated.
|
Copyright © 2018 Apache Software Foundation. All rights reserved.