| Modifier and Type | Method and Description |
|---|---|
void |
CoordinatorEngine.streamLog(java.lang.String jobId,
java.lang.String logRetrievalScope,
java.lang.String logRetrievalType,
java.io.Writer writer,
java.util.Map<java.lang.String,java.lang.String[]> params)
Add list of actions to the filter based on conditions
|
| Modifier and Type | Method and Description |
|---|---|
T |
XCommand.call()
Implements the XCommand life-cycle.
|
T |
XCommand.call(java.lang.String callerEntityKey)
Call this command synchronously from its caller.
|
protected void |
RerunTransitionXCommand.eagerLoadState() |
protected void |
XCommand.eagerLoadState()
Load the necessary state to perform an eager precondition check.
|
protected void |
RerunTransitionXCommand.eagerVerifyPrecondition() |
protected void |
XCommand.eagerVerifyPrecondition()
Verify the precondition for the command before obtaining a lock.
|
protected java.lang.Void |
StartTransitionXCommand.execute() |
protected T |
IgnoreTransitionXCommand.execute() |
protected java.lang.Void |
PurgeXCommand.execute() |
protected java.lang.Void |
ResumeTransitionXCommand.execute() |
protected java.lang.Void |
PauseTransitionXCommand.execute() |
protected java.lang.Void |
NotificationXCommand.execute() |
protected T |
RerunTransitionXCommand.execute() |
protected java.lang.Void |
StatusTransitXCommand.execute() |
protected java.lang.Void |
SuspendTransitionXCommand.execute() |
protected java.lang.Void |
UnpauseTransitionXCommand.execute() |
protected java.lang.String |
SubmitTransitionXCommand.execute() |
protected java.lang.Void |
MaterializeTransitionXCommand.execute() |
protected T |
TransitionXCommand.execute() |
protected T |
KillTransitionXCommand.execute() |
protected abstract T |
XCommand.execute()
Command execution body.
|
protected BulkResponseInfo |
BulkJobsXCommand.execute() |
void |
TransitionXCommand.generateEvents(CoordinatorJobBean coordJob,
java.util.Date startTime)
This will be used to generate Job Notification events on status changes
|
protected org.apache.oozie.client.Job.Status |
StatusTransitXCommand.getJobStatus()
Gets the job status.
|
abstract void |
IgnoreTransitionXCommand.ignoreChildren() |
abstract void |
KillTransitionXCommand.killChildren() |
protected void |
PurgeXCommand.loadState() |
protected abstract void |
XCommand.loadState()
Load the necessary state to perform the precondition check and to execute the command.
|
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 java.lang.String |
SubmitTransitionXCommand.submit()
Submit the job
|
abstract void |
SuspendTransitionXCommand.suspendChildren()
Suspend all children of the job
|
void |
IgnoreTransitionXCommand.transitToNext() |
void |
PauseTransitionXCommand.transitToNext() |
void |
UnpauseTransitionXCommand.transitToNext() |
void |
MaterializeTransitionXCommand.transitToNext() |
abstract void |
TransitionXCommand.transitToNext()
Transit to the next status based on the result of the Job.
|
abstract void |
UnpauseTransitionXCommand.unpauseChildren()
Unpause actions associated with the job
|
abstract void |
TransitionXCommand.updateJob()
Update the parent job.
|
protected abstract void |
StatusTransitXCommand.updateJobStatus(org.apache.oozie.client.Job.Status status)
Update job status.
|
protected void |
PurgeXCommand.verifyPrecondition() |
protected void |
NotificationXCommand.verifyPrecondition() |
protected void |
RerunTransitionXCommand.verifyPrecondition() |
protected abstract void |
XCommand.verifyPrecondition()
Verify the precondition for the command after a lock has been obtain, just before executing the command.
|
protected void |
BulkJobsXCommand.verifyPrecondition() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
BundleJobChangeXCommand.eagerLoadState() |
protected void |
BundleSubmitXCommand.eagerLoadState() |
protected void |
BundleJobChangeXCommand.eagerVerifyPrecondition() |
protected void |
BundleSubmitXCommand.eagerVerifyPrecondition() |
protected BundleJobInfo |
BundleJobsXCommand.execute() |
protected BundleJobInfo |
BulkBundleXCommand.execute() |
protected BundleJobBean |
BundleJobXCommand.execute() |
protected java.lang.Void |
BundleJobChangeXCommand.execute() |
protected java.lang.Void |
BundleStatusUpdateXCommand.execute() |
protected org.apache.oozie.client.Job.Status |
BundleStatusTransitXCommand.getJobStatus() |
void |
BundleKillXCommand.killChildren() |
protected void |
BundleJobsXCommand.loadState() |
void |
BundleStartXCommand.loadState() |
protected void |
BundleJobResumeXCommand.loadState() |
void |
BundlePauseXCommand.loadState() |
protected void |
BundleRerunXCommand.loadState() |
protected void |
BulkBundleXCommand.loadState() |
protected void |
BundleJobXCommand.loadState() |
void |
BundleUnpauseXCommand.loadState() |
protected void |
BundleJobChangeXCommand.loadState() |
protected void |
BundleJobSuspendXCommand.loadState() |
protected void |
BundleStatusTransitXCommand.loadState() |
protected void |
BundleSubmitXCommand.loadState() |
protected void |
BundleStatusUpdateXCommand.loadState() |
void |
BundleKillXCommand.loadState() |
protected void |
BundleSubmitXCommand.mergeDefaultConfig()
Merge default configuration with user-defined configuration.
|
void |
BundleJobResumeXCommand.notifyParent() |
void |
BundleRerunXCommand.notifyParent() |
void |
BundleJobSuspendXCommand.notifyParent() |
void |
BundleSubmitXCommand.notifyParent() |
void |
BundlePauseXCommand.pauseChildren() |
void |
BundleStartXCommand.performWrites() |
void |
BundleJobResumeXCommand.performWrites() |
void |
BundlePauseXCommand.performWrites() |
void |
BundleRerunXCommand.performWrites() |
void |
BundleUnpauseXCommand.performWrites() |
void |
BundleJobSuspendXCommand.performWrites() |
void |
BundleSubmitXCommand.performWrites() |
void |
BundleKillXCommand.performWrites() |
void |
BundleRerunXCommand.rerunChildren() |
void |
BundleStartXCommand.StartChildren() |
protected java.lang.String |
BundleSubmitXCommand.submit() |
void |
BundleJobSuspendXCommand.suspendChildren() |
void |
BundleUnpauseXCommand.unpauseChildren() |
void |
BundleStartXCommand.updateJob() |
void |
BundlePauseXCommand.updateJob() |
void |
BundleUnpauseXCommand.updateJob() |
void |
BundleSubmitXCommand.updateJob() |
protected void |
BundleJobsXCommand.verifyPrecondition() |
protected void |
BundleStartXCommand.verifyPrecondition() |
protected void |
BundleJobResumeXCommand.verifyPrecondition() |
protected void |
BundlePauseXCommand.verifyPrecondition() |
protected void |
BulkBundleXCommand.verifyPrecondition() |
protected void |
BundleJobXCommand.verifyPrecondition() |
protected void |
BundleUnpauseXCommand.verifyPrecondition() |
protected void |
BundleJobChangeXCommand.verifyPrecondition() |
protected void |
BundleJobSuspendXCommand.verifyPrecondition() |
protected void |
BundleStatusTransitXCommand.verifyPrecondition() |
protected void |
BundleSubmitXCommand.verifyPrecondition() |
protected void |
BundleStatusUpdateXCommand.verifyPrecondition() |
protected void |
BundleKillXCommand.verifyPrecondition() |
| Constructor and Description |
|---|
BundleJobChangeXCommand(java.lang.String id,
java.lang.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(java.lang.String startInst,
java.lang.String endInst) |
protected void |
CoordRerunXCommand.eagerLoadState() |
protected void |
CoordRerunXCommand.eagerVerifyPrecondition() |
protected java.lang.Void |
CoordActionTimeOutXCommand.execute() |
protected java.lang.Void |
CoordActionStartXCommand.execute() |
protected java.lang.Void |
CoordActionUpdateXCommand.execute() |
protected java.util.List<SLAEventBean> |
SLAEventsXCommand.execute() |
protected java.lang.Void |
CoordActionSkipXCommand.execute() |
protected CoordinatorJobInfo |
CoordJobsXCommand.execute() |
protected java.lang.Void |
CoordActionCheckXCommand.execute() |
protected CoordinatorActionBean |
CoordActionInfoXCommand.execute() |
protected CoordinatorJobInfo |
BulkCoordXCommand.execute() |
protected java.lang.Void |
CoordActionInputCheckXCommand.execute() |
protected java.lang.Void |
CoordChangeXCommand.execute() |
protected CoordinatorJobBean |
CoordJobXCommand.execute() |
protected java.lang.Void |
CoordActionReadyXCommand.execute() |
protected java.lang.Void |
CoordPushDependencyCheckXCommand.execute() |
protected java.lang.Void |
CoordActionUpdatePushMissingDependency.execute() |
protected org.apache.oozie.client.Job.Status |
CoordStatusTransitXCommand.getJobStatus() |
void |
CoordActionsIgnoreXCommand.ignoreChildren() |
void |
CoordKillXCommand.killChildren() |
void |
CoordActionsKillXCommand.killChildren() |
protected void |
CoordActionTimeOutXCommand.loadState() |
protected void |
CoordRerunXCommand.loadState() |
protected void |
CoordActionStartXCommand.loadState() |
protected void |
CoordActionUpdateXCommand.loadState() |
protected void |
SLAEventsXCommand.loadState() |
protected void |
CoordActionsIgnoreXCommand.loadState() |
protected void |
CoordKillXCommand.loadState() |
protected void |
CoordResumeXCommand.loadState() |
protected void |
CoordStatusTransitXCommand.loadState() |
void |
CoordPauseXCommand.loadState() |
protected void |
CoordActionNotificationXCommand.loadState() |
protected void |
CoordSuspendXCommand.loadState() |
protected void |
CoordActionSkipXCommand.loadState() |
protected void |
CoordJobsXCommand.loadState() |
void |
CoordUnpauseXCommand.loadState() |
protected void |
CoordActionCheckXCommand.loadState() |
protected void |
CoordActionsKillXCommand.loadState() |
protected void |
CoordActionInfoXCommand.loadState() |
protected void |
BulkCoordXCommand.loadState() |
protected void |
CoordActionInputCheckXCommand.loadState() |
protected void |
CoordChangeXCommand.loadState() |
protected void |
CoordJobXCommand.loadState() |
protected void |
CoordSubmitXCommand.loadState() |
protected void |
CoordUpdateXCommand.loadState() |
protected void |
CoordActionReadyXCommand.loadState() |
protected void |
CoordMaterializeTransitionXCommand.loadState() |
protected void |
CoordPushDependencyCheckXCommand.loadState() |
protected void |
CoordMaterializeTransitionXCommand.materialize() |
protected void |
CoordSubmitXCommand.mergeDefaultConfig()
Merge default configuration with user-defined configuration.
|
void |
CoordRerunXCommand.notifyParent() |
void |
CoordKillXCommand.notifyParent() |
void |
CoordResumeXCommand.notifyParent() |
void |
CoordPauseXCommand.notifyParent() |
void |
CoordSuspendXCommand.notifyParent() |
void |
CoordUnpauseXCommand.notifyParent() |
void |
CoordActionsKillXCommand.notifyParent() |
void |
CoordSubmitXCommand.notifyParent() |
void |
CoordUpdateXCommand.notifyParent() |
void |
CoordMaterializeTransitionXCommand.notifyParent() |
protected void |
CoordPushDependencyCheckXCommand.onAllPushDependenciesAvailable() |
void |
CoordPauseXCommand.pauseChildren() |
void |
CoordRerunXCommand.performWrites() |
void |
CoordActionsIgnoreXCommand.performWrites() |
void |
CoordKillXCommand.performWrites() |
void |
CoordResumeXCommand.performWrites() |
void |
CoordPauseXCommand.performWrites() |
void |
CoordSuspendXCommand.performWrites() |
void |
CoordUnpauseXCommand.performWrites() |
void |
CoordActionsKillXCommand.performWrites() |
void |
CoordSubmitXCommand.performWrites() |
void |
CoordMaterializeTransitionXCommand.performWrites() |
void |
CoordRerunXCommand.rerunChildren() |
void |
CoordResumeXCommand.resumeChildren() |
protected java.lang.String |
CoordSubmitXCommand.storeToDB(java.lang.String appXML,
org.jdom.Element eJob,
CoordinatorJobBean coordJob)
Write a coordinator job into database
|
protected java.lang.String |
CoordUpdateXCommand.storeToDB(java.lang.String xmlElement,
org.jdom.Element eJob,
CoordinatorJobBean coordJob) |
protected java.lang.String |
CoordSubmitXCommand.submit() |
protected java.lang.String |
CoordUpdateXCommand.submit() |
protected java.lang.String |
CoordSubmitXCommand.submitJob() |
void |
CoordSuspendXCommand.suspendChildren() |
void |
CoordMaterializeTransitionXCommand.transitToNext() |
void |
CoordUnpauseXCommand.unpauseChildren() |
protected void |
CoordPushDependencyCheckXCommand.updateCoordAction(CoordinatorActionBean coordAction,
boolean isChangeInDependency) |
void |
CoordKillXCommand.updateJob() |
void |
CoordPauseXCommand.updateJob() |
void |
CoordUnpauseXCommand.updateJob() |
void |
CoordActionsKillXCommand.updateJob() |
void |
CoordSubmitXCommand.updateJob() |
void |
CoordMaterializeTransitionXCommand.updateJob() |
protected void |
CoordStatusTransitXCommand.updateJobStatus(org.apache.oozie.client.Job.Status coordStatus) |
protected void |
CoordActionTimeOutXCommand.verifyPrecondition() |
protected void |
CoordRerunXCommand.verifyPrecondition() |
protected void |
CoordActionUpdateXCommand.verifyPrecondition() |
protected void |
SLAEventsXCommand.verifyPrecondition() |
protected void |
CoordActionsIgnoreXCommand.verifyPrecondition() |
protected void |
CoordKillXCommand.verifyPrecondition() |
protected void |
CoordResumeXCommand.verifyPrecondition() |
protected void |
CoordStatusTransitXCommand.verifyPrecondition() |
protected void |
CoordPauseXCommand.verifyPrecondition() |
protected void |
CoordSuspendXCommand.verifyPrecondition() |
protected void |
CoordActionSkipXCommand.verifyPrecondition() |
protected void |
CoordJobsXCommand.verifyPrecondition() |
protected void |
CoordUnpauseXCommand.verifyPrecondition() |
protected void |
CoordActionCheckXCommand.verifyPrecondition() |
protected void |
CoordActionsKillXCommand.verifyPrecondition() |
protected void |
CoordActionInfoXCommand.verifyPrecondition() |
protected void |
BulkCoordXCommand.verifyPrecondition() |
protected void |
CoordActionInputCheckXCommand.verifyPrecondition() |
protected void |
CoordChangeXCommand.verifyPrecondition() |
protected void |
CoordJobXCommand.verifyPrecondition() |
protected void |
CoordSubmitXCommand.verifyPrecondition() |
protected void |
CoordUpdateXCommand.verifyPrecondition() |
protected void |
CoordActionReadyXCommand.verifyPrecondition() |
protected void |
CoordMaterializeTransitionXCommand.verifyPrecondition() |
protected void |
CoordPushDependencyCheckXCommand.verifyPrecondition() |
| Constructor and Description |
|---|
CoordChangeXCommand(java.lang.String id,
java.lang.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 void |
ActionStartXCommand.callActionEnd() |
protected void |
SuspendXCommand.eagerLoadState() |
protected void |
CompletedActionXCommand.eagerLoadState() |
protected void |
ActionCheckXCommand.eagerLoadState() |
protected void |
ReRunXCommand.eagerLoadState()
Loading the Wfjob and workflow actions.
|
protected void |
SuspendXCommand.eagerVerifyPrecondition() |
protected void |
CompletedActionXCommand.eagerVerifyPrecondition() |
protected void |
ActionCheckXCommand.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 |
ActionStartXCommand.endWF() |
protected WorkflowJobBean |
JobXCommand.execute() |
protected java.lang.Void |
SuspendXCommand.execute() |
protected java.lang.String |
ExternalIdXCommand.execute() |
protected java.lang.String |
DefinitionXCommand.execute() |
protected java.lang.Void |
WfEndXCommand.execute() |
protected ActionXCommand.ActionExecutorContext |
ForkedActionStartXCommand.execute() |
protected WorkflowActionBean |
WorkflowActionInfoXCommand.execute() |
protected java.lang.Void |
CompletedActionXCommand.execute() |
protected java.lang.Void |
ActionCheckXCommand.execute() |
protected java.lang.Void |
KillXCommand.execute() |
protected java.lang.String |
SubmitXCommand.execute() |
protected java.lang.String |
SubmitHttpXCommand.execute() |
protected ActionXCommand.ActionExecutorContext |
ActionStartXCommand.execute() |
protected java.lang.Void |
SignalXCommand.execute() |
protected java.lang.Void |
ActionKillXCommand.execute() |
protected WorkflowsInfo |
JobsXCommand.execute() |
protected java.lang.Void |
ResumeXCommand.execute() |
protected WorkflowsInfo |
BulkWorkflowXCommand.execute() |
protected java.lang.Void |
ActionEndXCommand.execute() |
protected java.lang.Void |
ReRunXCommand.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,
java.lang.String message,
boolean isStart,
org.apache.oozie.client.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,
org.apache.oozie.client.WorkflowAction.Status status) |
protected void |
ActionXCommand.handleNonTransient(ActionExecutor.Context context,
ActionExecutor executor,
org.apache.oozie.client.WorkflowAction.Status status)
Takes care of non transient failures.
|
protected boolean |
ActionXCommand.handleTransient(ActionExecutor.Context context,
ActionExecutor executor,
org.apache.oozie.client.WorkflowAction.Status status)
Takes care of Transient failures.
|
boolean |
ActionXCommand.handleUserRetry(WorkflowActionBean action)
Execute retry for action if this action is eligible for user-retry
|
protected void |
JobXCommand.loadState() |
protected void |
SuspendXCommand.loadState() |
protected void |
ExternalIdXCommand.loadState() |
protected void |
DefinitionXCommand.loadState() |
protected void |
WfEndXCommand.loadState() |
protected void |
WorkflowNotificationXCommand.loadState() |
protected void |
CompletedActionXCommand.loadState() |
protected void |
ActionCheckXCommand.loadState() |
protected void |
KillXCommand.loadState() |
protected void |
ActionStartXCommand.loadState() |
protected void |
SignalXCommand.loadState() |
protected void |
ActionKillXCommand.loadState() |
protected void |
JobsXCommand.loadState() |
protected void |
ResumeXCommand.loadState() |
protected void |
BulkWorkflowXCommand.loadState() |
protected void |
ActionEndXCommand.loadState() |
protected void |
ReRunXCommand.loadState() |
static java.lang.String |
SubmitXCommand.resolveSla(org.jdom.Element eSla,
ELEvaluator evalSla)
Resolve variables in sla xml element.
|
void |
SignalXCommand.startForkedActions(java.util.List<WorkflowActionBean> workflowActionBeanListForForked) |
void |
SignalXCommand.startForkedActionsByQueuing(java.util.List<WorkflowActionBean> workflowActionBeanListForForked) |
static void |
SuspendXCommand.suspendJob(JPAService jpaService,
WorkflowJobBean workflow,
java.lang.String id,
java.lang.String actionId,
java.util.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 |
ForkedActionStartXCommand.updateParentIfNecessary(WorkflowJobBean wfjob,
int maxRetries) |
protected void |
WorkflowXCommand.updateParentIfNecessary(WorkflowJobBean wfjob,
int maxRetries) |
protected void |
SubmitSqoopXCommand.verifyPrecondition() |
protected void |
JobXCommand.verifyPrecondition() |
protected void |
SuspendXCommand.verifyPrecondition() |
protected void |
ExternalIdXCommand.verifyPrecondition() |
protected void |
DefinitionXCommand.verifyPrecondition() |
protected void |
WfEndXCommand.verifyPrecondition() |
protected void |
WorkflowActionInfoXCommand.verifyPrecondition() |
protected void |
CompletedActionXCommand.verifyPrecondition() |
protected void |
ActionCheckXCommand.verifyPrecondition() |
protected void |
SubmitScriptLanguageXCommand.verifyPrecondition() |
protected void |
KillXCommand.verifyPrecondition() |
protected void |
SubmitXCommand.verifyPrecondition() |
protected void |
SubmitMRXCommand.verifyPrecondition() |
protected void |
ActionStartXCommand.verifyPrecondition() |
protected void |
SignalXCommand.verifyPrecondition() |
protected void |
ActionKillXCommand.verifyPrecondition() |
protected void |
JobsXCommand.verifyPrecondition() |
protected void |
ResumeXCommand.verifyPrecondition() |
protected void |
BulkWorkflowXCommand.verifyPrecondition() |
protected void |
ActionEndXCommand.verifyPrecondition() |
protected void |
ReRunXCommand.verifyPrecondition() |
| Modifier and Type | Method and Description |
|---|---|
static java.util.List<CoordinatorActionBean> |
CoordUtils.getCoordActions(java.lang.String rangeType,
java.lang.String jobId,
java.lang.String scope,
boolean active)
Get the list of actions for a given coordinator job
|
static java.util.List<CoordinatorActionBean> |
CoordUtils.getCoordActionsFromIds(java.lang.String jobId,
java.lang.String scope)
Get the list of actions for given id ranges
|
| Modifier and Type | Method and Description |
|---|---|
static ActionDependency |
DependencyChecker.checkForAvailability(java.lang.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(java.lang.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,
java.lang.String jobId,
org.apache.oozie.AppType appType,
java.lang.String user,
java.lang.String appName,
XLog log) |
static SLARegistrationBean |
SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla,
java.lang.String jobId,
org.apache.oozie.AppType appType,
java.lang.String user,
XLog log) |
static SLARegistrationBean |
SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla,
java.lang.String jobId,
java.lang.String parentId,
org.apache.oozie.AppType appType,
java.lang.String user,
java.lang.String appName,
XLog log,
boolean rerun) |
static SLARegistrationBean |
SLAOperations.createSlaRegistrationEvent(org.jdom.Element eSla,
java.lang.String jobId,
java.lang.String parentId,
org.apache.oozie.AppType appType,
java.lang.String user,
XLog log) |
static void |
SLAOperations.updateRegistrationEvent(java.lang.String jobId)
Retrieve registration event
|
| Modifier and Type | Method and Description |
|---|---|
static void |
PropertiesUtils.checkDisallowedProperties(org.apache.hadoop.conf.Configuration conf,
java.util.Set<java.lang.String> set)
Validate against DISALLOWED Properties.
|
static java.util.Date |
CoordActionsInDateRange.getCoordActionsLastModifiedDate(java.lang.String jobId,
java.lang.String startAction,
java.lang.String endAction)
Gets the coordinator actions last modified date for range, if any action is running it return new date
|
static java.util.Map<java.lang.String,java.lang.String> |
JobUtils.parseChangeValue(java.lang.String changeValue)
This Function will parse the value of the changed values in key value manner.
|
void |
XLogUserFilterParam.validateLogLevel(java.lang.String loglevel)
Validate log level.
|
void |
XLogUserFilterParam.validateSearchText()
Validate search text.
|
| Constructor and Description |
|---|
XLogUserFilterParam(java.util.Map<java.lang.String,java.lang.String[]> params)
Instantiates a new log user param.
|
| Modifier and Type | Method and Description |
|---|---|
static SLAEventBean |
SLADbXOperations.createStatusEvent(java.lang.String slaXml,
java.lang.String id,
org.apache.oozie.client.SLAEvent.Status stat,
org.apache.oozie.client.SLAEvent.SlaAppType appType)
Deprecated.
Create SLA status event
|
static SLAEventBean |
SLADbOperations.createStatusEvent(java.lang.String slaXml,
java.lang.String id,
org.apache.oozie.client.SLAEvent.Status stat,
org.apache.oozie.client.SLAEvent.SlaAppType appType,
XLog log)
Deprecated.
|
Copyright © 2017 Apache Software Foundation. All Rights Reserved.