void |
CoordinatorEngine.change(String jobId,
String changeValue) |
String |
CoordinatorEngine.dryRunSubmit(org.apache.hadoop.conf.Configuration conf) |
CoordinatorJobInfo |
CoordinatorEngine.getCoordJobs(String filter,
int start,
int len) |
String |
CoordinatorEngine.getJobIdForExternalId(String externalId) |
void |
CoordinatorEngine.kill(String jobId) |
void |
CoordinatorEngine.resume(String jobId) |
String |
CoordinatorEngine.submitJob(org.apache.hadoop.conf.Configuration conf,
boolean startJob) |
void |
CoordinatorEngine.suspend(String jobId) |