Package | Description |
---|---|
org.apache.oozie |
Modifier and Type | Method and Description |
---|---|
void |
BundleEngine.change(String jobId,
String changeValue) |
String |
BundleEngine.dryRunSubmit(org.apache.hadoop.conf.Configuration conf) |
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,
boolean desc) |
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,
Map<String,String[]> params) |
String |
BundleEngine.submitJob(org.apache.hadoop.conf.Configuration conf,
boolean startJob) |
void |
BundleEngine.suspend(String jobId) |
Copyright © 2014 Apache Software Foundation. All Rights Reserved.