| Modifier and Type | Method and Description |
|---|---|
CoordinatorJobBean |
CoordinatorEngine.getCoordJob(java.lang.String jobId) |
CoordinatorJobBean |
CoordinatorEngine.getCoordJob(java.lang.String jobId,
java.lang.String filter,
int offset,
int length,
boolean desc) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<CoordinatorJobBean> |
CoordinatorJobInfo.getCoordJobs()
Return the coordiantor jobs being returned.
|
| Modifier and Type | Method and Description |
|---|---|
void |
BundleJobBean.setCoordJobs(java.util.List<CoordinatorJobBean> coordJobs)
Set coordJobs
|
static org.json.simple.JSONArray |
CoordinatorJobBean.toJSONArray(java.util.List<CoordinatorJobBean> applications,
java.lang.String timeZoneId)
Convert a coordinator application list into a JSONArray.
|
| Constructor and Description |
|---|
CoordinatorJobInfo(java.util.List<CoordinatorJobBean> jobs,
int start,
int len,
int total)
Create a coordinator info bean.
|
| Modifier and Type | Method and Description |
|---|---|
CoordinatorJobBean |
BulkResponseImpl.getCoordinator() |
| Modifier and Type | Method and Description |
|---|---|
void |
BulkResponseImpl.setCoordinator(CoordinatorJobBean cj)
Sets the coordinator comprising this bulk response object
|
| Modifier and Type | Method and Description |
|---|---|
void |
TransitionXCommand.generateEvents(CoordinatorJobBean coordJob,
java.util.Date startTime)
This will be used to generate Job Notification events on status changes
|
| Constructor and Description |
|---|
BundleStatusUpdateXCommand(CoordinatorJobBean coordjob,
org.apache.oozie.client.Job.Status prevStatus)
The constructor for class
BundleStatusUpdateXCommand |
BundleStatusUpdateXCommand(CoordinatorJobBean coordjob,
org.apache.oozie.client.Job.Status prevStatus,
boolean ignorePending) |
| Modifier and Type | Field and Description |
|---|---|
protected CoordinatorJobBean |
CoordSubmitXCommand.coordJob |
protected CoordinatorJobBean |
CoordPushDependencyCheckXCommand.coordJob |
| Modifier and Type | Method and Description |
|---|---|
protected CoordinatorJobBean |
CoordJobXCommand.execute() |
| Modifier and Type | Method and Description |
|---|---|
org.jdom.Element |
CoordSubmitXCommand.basicResolveAndIncludeDS(java.lang.String appXml,
org.apache.hadoop.conf.Configuration conf,
CoordinatorJobBean coordJob)
The method resolve all the variables that are defined in configuration.
|
void |
CoordUpdateXCommand.check(CoordinatorJobBean oldCoord,
CoordinatorJobBean newCoord)
Check.
|
static java.util.Date |
CoordCommandUtils.computeNextNominalTime(CoordinatorJobBean coordJob,
CoordinatorActionBean coordAction)
Computes the nominal time of the next action.
|
protected void |
CoordinatorXCommand.generateEvent(CoordinatorJobBean coordJob) |
java.lang.String |
CoordUpdateXCommand.getDryRun(CoordinatorJobBean job) |
protected java.lang.String |
CoordSubmitXCommand.getDryRun(CoordinatorJobBean coordJob)
Gets the dryrun output.
|
static java.util.Date |
CoordCommandUtils.getNextValidActionTimeForCronFrequency(java.util.Date targetDate,
CoordinatorJobBean coordJob)
Get the next action time after a given time
|
protected org.jdom.Element |
CoordSubmitXCommand.resolveInitial(org.apache.hadoop.conf.Configuration conf,
java.lang.String appXml,
CoordinatorJobBean coordJob)
Resolve basic entities using job Configuration.
|
protected java.lang.String |
CoordUpdateXCommand.storeToDB(java.lang.String xmlElement,
org.jdom.Element eJob,
CoordinatorJobBean coordJob) |
protected java.lang.String |
CoordSubmitXCommand.storeToDB(java.lang.String appXML,
org.jdom.Element eJob,
CoordinatorJobBean coordJob)
Write a coordinator job into database
|
| Constructor and Description |
|---|
CoordMaterializeTransitionXCommand(CoordinatorJobBean coordJob,
int materializationWindow,
java.util.Date startTime,
java.util.Date endTime) |
CoordPauseXCommand(CoordinatorJobBean coordJob) |
CoordUnpauseXCommand(CoordinatorJobBean coordJob) |
| Modifier and Type | Method and Description |
|---|---|
CoordinatorJobBean |
CoordJobGetJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorJobBean |
CoordinatorJobGetForUserAppnameJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorJobBean |
CoordJobQueryExecutor.get(CoordJobQueryExecutor.CoordJobQuery namedQuery,
java.lang.Object... parameters) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<CoordinatorJobBean> |
CoordJobsGetPendingJPAExecutor.execute(javax.persistence.EntityManager em) |
java.util.List<CoordinatorJobBean> |
BundleJobGetCoordinatorsJPAExecutor.execute(javax.persistence.EntityManager em) |
java.util.List<CoordinatorJobBean> |
CoordJobsToBeMaterializedJPAExecutor.execute(javax.persistence.EntityManager em) |
java.util.List<CoordinatorJobBean> |
CoordJobsGetUnpausedJPAExecutor.execute(javax.persistence.EntityManager em) |
java.util.List<CoordinatorJobBean> |
CoordJobsGetPausedJPAExecutor.execute(javax.persistence.EntityManager em) |
java.util.List<CoordinatorJobBean> |
CoordJobQueryExecutor.getList(CoordJobQueryExecutor.CoordJobQuery namedQuery,
java.lang.Object... parameters) |
| Modifier and Type | Method and Description |
|---|---|
int |
CoordJobQueryExecutor.executeUpdate(CoordJobQueryExecutor.CoordJobQuery namedQuery,
CoordinatorJobBean jobBean) |
javax.persistence.Query |
CoordJobQueryExecutor.getUpdateQuery(CoordJobQueryExecutor.CoordJobQuery namedQuery,
CoordinatorJobBean cjBean,
javax.persistence.EntityManager em) |
| Constructor and Description |
|---|
CoordJobInsertJPAExecutor(CoordinatorJobBean coordJob) |
| Modifier and Type | Method and Description |
|---|---|
void |
AbandonedCoordCheckerService.AbandonedCoordCheckerRunnable.addCoordToMessage(CoordinatorJobBean job,
java.lang.String killStatus,
java.lang.StringBuilder msg) |
| Modifier and Type | Method and Description |
|---|---|
static org.apache.oozie.client.Job.Status |
StatusUtils.getStatus(CoordinatorJobBean coordJob)
This Function transforms the statuses based on the name space of the coordinator App
|
static boolean |
StatusUtils.getStatusForCoordActionInputCheck(CoordinatorJobBean coordJob)
This function check if eligible to do action input check when running with backward support is true.
|
static org.apache.oozie.client.Job.Status |
StatusUtils.getStatusForCoordRerun(CoordinatorJobBean coordJob,
org.apache.oozie.client.Job.Status prevStatus)
This function changes back the status for coordinator rerun if the job was SUCCEEDED or SUSPENDED when rerun
with backward support is true.
|
static boolean |
StatusUtils.isV1CoordjobKillable(CoordinatorJobBean coordJob)
If namespace 0.1 is used and backward support is true, SUCCEEDED coord job can be killed
|
static void |
LogUtils.setLogInfo(CoordinatorJobBean cBean)
Set the thread local log info with the context of the given coordinator bean.
|
Copyright © 2019 Apache Software Foundation. All Rights Reserved.