| Methods in org.apache.oozie that throw BundleEngineException |
void |
BundleEngine.change(String jobId,
String changeValue)
|
String |
BundleEngine.dryrunSubmit(org.apache.hadoop.conf.Configuration conf,
boolean startJob)
|
BulkResponseInfo |
BundleEngine.getBulkJobs(String bulkFilter,
int start,
int len)
Get bulk job response |
BundleJobBean |
BundleEngine.getBundleJob(String jobId)
|
BundleJobInfo |
BundleEngine.getBundleJobs(String filter,
int start,
int len)
Get bundle jobs |
org.apache.oozie.client.CoordinatorJob |
BundleEngine.getCoordJob(String jobId)
|
org.apache.oozie.client.CoordinatorJob |
BundleEngine.getCoordJob(String jobId,
String filter,
int start,
int length)
|
String |
BundleEngine.getDefinition(String jobId)
|
org.apache.oozie.client.WorkflowJob |
BundleEngine.getJob(String jobId)
|
org.apache.oozie.client.WorkflowJob |
BundleEngine.getJob(String jobId,
int start,
int length)
|
String |
BundleEngine.getJobIdForExternalId(String externalId)
|
void |
BundleEngine.kill(String jobId)
|
static Map<String,List<String>> |
BundleEngine.parseBulkFilter(String bulkParams)
Parse filter string to a map with key = filter name and values = filter values
Allowed keys are defined as constants on top |
void |
BundleEngine.reRun(String jobId,
org.apache.hadoop.conf.Configuration conf)
Deprecated. |
void |
BundleEngine.resume(String jobId)
|
void |
BundleEngine.start(String jobId)
|
void |
BundleEngine.streamLog(String jobId,
Writer writer)
|
String |
BundleEngine.submitJob(org.apache.hadoop.conf.Configuration conf,
boolean startJob)
|
void |
BundleEngine.suspend(String jobId)
|