Modifier and Type | Method and Description |
---|---|
CoordinatorJobBean |
CoordinatorEngine.getCoordJob(String jobId) |
CoordinatorJobBean |
CoordinatorEngine.getCoordJob(String jobId,
String filter,
int offset,
int length,
boolean desc) |
Modifier and Type | Method and Description |
---|---|
List<CoordinatorJobBean> |
CoordinatorJobInfo.getCoordJobs()
Return the coordiantor jobs being returned.
|
Modifier and Type | Method and Description |
---|---|
void |
BundleJobBean.setCoordJobs(List<CoordinatorJobBean> coordJobs)
Set coordJobs
|
static org.json.simple.JSONArray |
CoordinatorJobBean.toJSONArray(List<CoordinatorJobBean> applications,
String timeZoneId)
Convert a coordinator application list into a JSONArray.
|
Constructor and Description |
---|
CoordinatorJobInfo(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,
Date startTime)
This will be used to generate Job Notification events on status changes
|
protected void |
Command.setLogInfo(CoordinatorJobBean cBean)
Set the log info with the context of the given coordinator bean.
|
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(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.
|
protected void |
CoordinatorXCommand.generateEvent(CoordinatorJobBean coordJob) |
String |
CoordUpdateXCommand.getDryRun(CoordinatorJobBean job) |
protected String |
CoordSubmitXCommand.getDryRun(CoordinatorJobBean coordJob)
Gets the dryrun output.
|
static Date |
CoordCommandUtils.getNextValidActionTimeForCronFrequency(Date targetDate,
CoordinatorJobBean coordJob)
Get the next action time after a given time
|
protected String |
CoordActionMaterializeCommand.materializeJobs(boolean dryrun,
CoordinatorJobBean jobBean,
org.apache.hadoop.conf.Configuration conf,
CoordinatorStore store)
Create action instances starting from "start-time" to end-time" and store them into Action table.
|
protected org.jdom.Element |
CoordSubmitXCommand.resolveInitial(org.apache.hadoop.conf.Configuration conf,
String appXml,
CoordinatorJobBean coordJob)
Resolve basic entities using job Configuration.
|
protected String |
CoordUpdateXCommand.storeToDB(String xmlElement,
org.jdom.Element eJob,
CoordinatorJobBean coordJob) |
protected String |
CoordSubmitXCommand.storeToDB(String appXML,
org.jdom.Element eJob,
CoordinatorJobBean coordJob)
Write a coordinator job into database
|
Constructor and Description |
---|
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,
Object... parameters) |
Modifier and Type | Method and Description |
---|---|
List<CoordinatorJobBean> |
CoordJobsToBeMaterializedJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorJobBean> |
CoordJobsGetUnpausedJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorJobBean> |
CoordJobsGetPendingJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorJobBean> |
CoordJobsGetPausedJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorJobBean> |
BundleJobGetCoordinatorsJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorJobBean> |
CoordJobQueryExecutor.getList(CoordJobQueryExecutor.CoordJobQuery namedQuery,
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 |
---|---|
CoordinatorJobBean |
CoordinatorStore.getCoordinatorJob(String id,
boolean locking)
Load the CoordinatorJob into a Bean and return it.
|
CoordinatorJobBean |
CoordinatorStore.getCoordinatorJobs(String id) |
Modifier and Type | Method and Description |
---|---|
List<CoordinatorJobBean> |
CoordinatorStore.getCoordinatorJobsOlderThanStatus(long checkAgeSecs,
String status,
int limit,
boolean locking)
A list of Coordinator Jobs that are matched with the status and have last materialized time' older than
checkAgeSecs will be returned.
|
List<CoordinatorJobBean> |
CoordinatorStore.getCoordinatorJobsToBeMaterialized(Date d,
int limit)
Get a list of Coordinator Jobs that should be materialized.
|
Modifier and Type | Method and Description |
---|---|
void |
CoordinatorStore.insertCoordinatorJob(CoordinatorJobBean coordinatorJob)
Create a CoordJobBean.
|
void |
CoordinatorStore.updateCoordinatorJob(CoordinatorJobBean job)
Update the given coordinator job bean to DB.
|
void |
CoordinatorStore.updateCoordinatorJobStatus(CoordinatorJobBean job) |
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,
XLog.Info logInfo)
Set the log info with the context of the given coordinator bean.
|
Copyright © 2014 Apache Software Foundation. All Rights Reserved.