|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of CoordinatorJobBean in org.apache.oozie |
---|
Methods in org.apache.oozie that return CoordinatorJobBean | |
---|---|
CoordinatorJobBean |
CoordinatorEngine.getCoordJob(String jobId)
|
CoordinatorJobBean |
CoordinatorEngine.getCoordJob(String jobId,
String filter,
int start,
int length,
boolean desc)
|
Methods in org.apache.oozie that return types with arguments of type CoordinatorJobBean | |
---|---|
List<CoordinatorJobBean> |
CoordinatorJobInfo.getCoordJobs()
Return the coordiantor jobs being returned. |
Constructor parameters in org.apache.oozie with type arguments of type CoordinatorJobBean | |
---|---|
CoordinatorJobInfo(List<CoordinatorJobBean> jobs,
int start,
int len,
int total)
Create a coordinator info bean. |
Uses of CoordinatorJobBean in org.apache.oozie.client.rest |
---|
Methods in org.apache.oozie.client.rest that return CoordinatorJobBean | |
---|---|
CoordinatorJobBean |
BulkResponseImpl.getCoordinator()
|
Methods in org.apache.oozie.client.rest with parameters of type CoordinatorJobBean | |
---|---|
void |
BulkResponseImpl.setCoordinator(CoordinatorJobBean cj)
Sets the coordinator comprising this bulk response object |
Uses of CoordinatorJobBean in org.apache.oozie.command |
---|
Methods in org.apache.oozie.command with parameters of type CoordinatorJobBean | |
---|---|
void |
TransitionXCommand.generateEvents(CoordinatorJobBean coordJob)
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. |
Uses of CoordinatorJobBean in org.apache.oozie.command.bundle |
---|
Constructors in org.apache.oozie.command.bundle with parameters of type CoordinatorJobBean | |
---|---|
BundleStatusUpdateXCommand(CoordinatorJobBean coordjob,
org.apache.oozie.client.Job.Status prevStatus)
The constructor for class BundleStatusUpdateXCommand |
Uses of CoordinatorJobBean in org.apache.oozie.command.coord |
---|
Fields in org.apache.oozie.command.coord declared as CoordinatorJobBean | |
---|---|
protected CoordinatorJobBean |
CoordPushDependencyCheckXCommand.coordJob
|
Methods in org.apache.oozie.command.coord that return CoordinatorJobBean | |
---|---|
protected CoordinatorJobBean |
CoordJobXCommand.execute()
|
Methods in org.apache.oozie.command.coord with parameters of type CoordinatorJobBean | |
---|---|
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. |
protected void |
CoordinatorXCommand.generateEvent(CoordinatorJobBean coordJob)
|
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. |
Constructors in org.apache.oozie.command.coord with parameters of type CoordinatorJobBean | |
---|---|
CoordPauseXCommand(CoordinatorJobBean coordJob)
|
|
CoordUnpauseXCommand(CoordinatorJobBean coordJob)
|
Uses of CoordinatorJobBean in org.apache.oozie.executor.jpa |
---|
Methods in org.apache.oozie.executor.jpa that return CoordinatorJobBean | |
---|---|
CoordinatorJobBean |
CoordJobGetJPAExecutor.execute(javax.persistence.EntityManager em)
|
CoordinatorJobBean |
CoordinatorJobGetForUserAppnameJPAExecutor.execute(javax.persistence.EntityManager em)
|
Methods in org.apache.oozie.executor.jpa that return types with arguments of type CoordinatorJobBean | |
---|---|
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)
|
Constructors in org.apache.oozie.executor.jpa with parameters of type CoordinatorJobBean | |
---|---|
CoordJobInsertJPAExecutor(CoordinatorJobBean coordJob)
|
|
CoordJobUpdateJPAExecutor(CoordinatorJobBean coordJob)
|
Uses of CoordinatorJobBean in org.apache.oozie.store |
---|
Methods in org.apache.oozie.store that return CoordinatorJobBean | |
---|---|
CoordinatorJobBean |
CoordinatorStore.getCoordinatorJob(String id,
boolean locking)
Load the CoordinatorJob into a Bean and return it. |
CoordinatorJobBean |
CoordinatorStore.getCoordinatorJobs(String id)
|
Methods in org.apache.oozie.store that return types with arguments of type CoordinatorJobBean | |
---|---|
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. |
Methods in org.apache.oozie.store with parameters of type CoordinatorJobBean | |
---|---|
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)
|
Uses of CoordinatorJobBean in org.apache.oozie.util |
---|
Methods in org.apache.oozie.util with parameters of type CoordinatorJobBean | |
---|---|
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. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |