Package | Description |
---|---|
org.apache.oozie |
Modifier and Type | Method and Description |
---|---|
void |
CoordinatorEngine.change(String jobId,
String changeValue) |
String |
CoordinatorEngine.dryRunSubmit(org.apache.hadoop.conf.Configuration conf) |
String |
CoordinatorEngine.getActionStatus(String actionId)
Return the status for an Action ID
|
CoordinatorJobInfo |
CoordinatorEngine.getCoordJobs(String filter,
int start,
int len) |
String |
CoordinatorEngine.getJobIdForExternalId(String externalId) |
String |
CoordinatorEngine.getJobStatus(String jobId)
Return the status for a Job ID
|
List<WorkflowJobBean> |
CoordinatorEngine.getReruns(String coordActionId) |
CoordinatorActionInfo |
CoordinatorEngine.ignore(String jobId,
String type,
String scope) |
void |
CoordinatorEngine.kill(String jobId) |
CoordinatorActionInfo |
CoordinatorEngine.killActions(String jobId,
String rangeType,
String scope) |
CoordinatorJobInfo |
CoordinatorEngine.killJobs(String filter,
int start,
int length)
return a list of killed Coordinator job
|
Map<Pair<String,CoordinatorEngine.FILTER_COMPARATORS>,List<Object>> |
CoordinatorEngine.parseJobFilter(String filter) |
void |
CoordinatorEngine.resume(String jobId) |
CoordinatorJobInfo |
CoordinatorEngine.resumeJobs(String filter,
int start,
int length)
return the jobs that've been resumed
|
String |
CoordinatorEngine.submitJob(org.apache.hadoop.conf.Configuration conf,
boolean startJob) |
void |
CoordinatorEngine.suspend(String jobId) |
CoordinatorJobInfo |
CoordinatorEngine.suspendJobs(String filter,
int start,
int length)
return the jobs that've been suspended
|
String |
CoordinatorEngine.updateJob(org.apache.hadoop.conf.Configuration conf,
String jobId,
boolean dryrun,
boolean showDiff)
Update coord job definition.
|
Copyright © 2018 Apache Software Foundation. All rights reserved.