Package | Description |
---|---|
org.apache.oozie | |
org.apache.oozie.command.wf | |
org.apache.oozie.executor.jpa | |
org.apache.oozie.store |
Modifier and Type | Method and Description |
---|---|
WorkflowsInfo |
DagEngine.getJobs(String filter,
int start,
int len)
Return the info about a set of jobs.
|
WorkflowsInfo |
DagEngine.killJobs(String filter,
int start,
int len)
return the jobs that've been killed
|
WorkflowsInfo |
DagEngine.resumeJobs(String filter,
int start,
int len)
return the jobs that've been resumed
|
WorkflowsInfo |
DagEngine.suspendJobs(String filter,
int start,
int len)
return the jobs that've been suspended
|
Modifier and Type | Method and Description |
---|---|
static org.json.simple.JSONObject |
OozieJsonFactory.getWFJSONObject(WorkflowsInfo jobs,
String timeZoneId) |
Modifier and Type | Method and Description |
---|---|
protected WorkflowsInfo |
JobsXCommand.execute() |
protected WorkflowsInfo |
BulkWorkflowXCommand.execute() |
Modifier and Type | Method and Description |
---|---|
WorkflowsInfo |
WorkflowsJobGetJPAExecutor.execute(javax.persistence.EntityManager em) |
Modifier and Type | Method and Description |
---|---|
WorkflowsInfo |
WorkflowStore.getWorkflowsInfo(Map<String,List<String>> filter,
int start,
int len)
Loads all the jobs that are satisfying the given filter condition.
|
Copyright © 2018 Apache Software Foundation. All rights reserved.