| Package | Description |
|---|---|
| org.apache.oozie |
| Modifier and Type | Method and Description |
|---|---|
void |
DagEngine.change(java.lang.String jobId,
java.lang.String changeValue) |
java.lang.String |
DagEngine.getDefinition(java.lang.String jobId)
Return the a job definition.
|
java.lang.String |
BaseEngine.getJMSTopicName(java.lang.String jobId)
Return the jms topic name for the job.
|
org.apache.oozie.client.WorkflowJob |
DagEngine.getJob(java.lang.String jobId)
Return the info about a job.
|
org.apache.oozie.client.WorkflowJob |
DagEngine.getJob(java.lang.String jobId,
int start,
int length)
Return the info about a job with actions subset.
|
java.lang.String |
DagEngine.getJobIdForExternalId(java.lang.String externalId)
Return the workflow Job ID for an external ID.
|
WorkflowsInfo |
DagEngine.getJobs(java.lang.String filter,
int start,
int len)
Return the info about a set of jobs.
|
java.lang.String |
DagEngine.getJobStatus(java.lang.String jobId)
Return the status for a Job ID
|
void |
DagEngine.kill(java.lang.String jobId)
Kill a job.
|
WorkflowsInfo |
DagEngine.killJobs(java.lang.String filter,
int start,
int len)
return the jobs that've been killed
|
protected java.util.Map<java.lang.String,java.util.List<java.lang.String>> |
DagEngine.parseFilter(java.lang.String filter)
Validate a jobs filter.
|
void |
DagEngine.processCallback(java.lang.String actionId,
java.lang.String externalStatus,
java.util.Properties actionData)
Process an action callback.
|
void |
DagEngine.reRun(java.lang.String jobId,
org.apache.hadoop.conf.Configuration conf)
Rerun a job.
|
void |
DagEngine.resume(java.lang.String jobId)
Resume a job.
|
WorkflowsInfo |
DagEngine.resumeJobs(java.lang.String filter,
int start,
int len)
return the jobs that've been resumed
|
void |
DagEngine.start(java.lang.String jobId)
Start a job.
|
void |
DagEngine.streamLog(java.lang.String jobId,
java.io.Writer writer,
java.util.Map<java.lang.String,java.lang.String[]> params)
Stream the log of a job.
|
java.lang.String |
DagEngine.submitHttpJob(org.apache.hadoop.conf.Configuration conf,
java.lang.String jobType)
Submit a pig/hive/mapreduce job through HTTP.
|
java.lang.String |
DagEngine.submitJob(org.apache.hadoop.conf.Configuration conf,
boolean startJob)
Submit a workflow job.
|
java.lang.String |
DagEngine.submitJobFromCoordinator(org.apache.hadoop.conf.Configuration conf,
java.lang.String parentId)
Submit a workflow through a coordinator.
|
void |
DagEngine.suspend(java.lang.String jobId)
Suspend a job.
|
WorkflowsInfo |
DagEngine.suspendJobs(java.lang.String filter,
int start,
int len)
return the jobs that've been suspended
|
Copyright © 2017 Apache Software Foundation. All Rights Reserved.