| Package | Description |
|---|---|
| org.apache.oozie | |
| org.apache.oozie.client.rest | |
| org.apache.oozie.command.coord | |
| org.apache.oozie.coord | |
| org.apache.oozie.executor.jpa | |
| org.apache.oozie.util |
| Modifier and Type | Method and Description |
|---|---|
CoordinatorActionBean |
CoordinatorEngine.getCoordAction(String actionId) |
| Modifier and Type | Method and Description |
|---|---|
List<CoordinatorActionBean> |
CoordinatorActionInfo.getCoordActions()
Return the coordiantor actions being returned.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CoordinatorJobBean.setActions(List<CoordinatorActionBean> nodes) |
static org.json.simple.JSONArray |
CoordinatorActionBean.toJSONArray(List<CoordinatorActionBean> actions,
String timeZoneId)
Convert a nodes list into a JSONArray.
|
| Constructor and Description |
|---|
CoordinatorActionInfo(List<CoordinatorActionBean> actions)
Create a coordiantor actions info bean.
|
| Modifier and Type | Method and Description |
|---|---|
CoordinatorActionBean |
BulkResponseImpl.getAction() |
| Modifier and Type | Method and Description |
|---|---|
void |
BulkResponseImpl.setAction(CoordinatorActionBean ca)
Sets the coord action comprising this bulk response object
|
| Modifier and Type | Field and Description |
|---|---|
protected CoordinatorActionBean |
CoordPushDependencyCheckXCommand.coordAction |
| Modifier and Type | Method and Description |
|---|---|
protected CoordinatorActionBean |
CoordActionInfoXCommand.execute() |
| Modifier and Type | Method and Description |
|---|---|
static Date |
CoordCommandUtils.computeNextNominalTime(CoordinatorJobBean coordJob,
CoordinatorActionBean coordAction)
Computes the nominal time of the next action.
|
static void |
CoordinatorXCommand.generateEvent(CoordinatorActionBean coordAction,
String user,
String appName,
Date startTime) |
static String |
CoordCommandUtils.materializeOneInstance(String jobId,
boolean dryrun,
org.jdom.Element eAction,
Date nominalTime,
Date actualTime,
int instanceCount,
org.apache.hadoop.conf.Configuration conf,
CoordinatorActionBean actionBean)
Materialize one instance for specific nominal time.
|
static boolean |
CoordCommandUtils.materializeSLA(org.jdom.Element eAction,
CoordinatorActionBean coordAction,
org.apache.hadoop.conf.Configuration conf) |
protected void |
CoordPushDependencyCheckXCommand.updateCoordAction(CoordinatorActionBean coordAction,
boolean isChangeInDependency) |
| Constructor and Description |
|---|
CoordActionNotificationXCommand(CoordinatorActionBean actionBean) |
CoordActionSkipXCommand(CoordinatorActionBean actionBean,
String user,
String appName) |
CoordActionTimeOutXCommand(CoordinatorActionBean actionBean,
String user,
String appName) |
| Modifier and Type | Method and Description |
|---|---|
static List<CoordinatorActionBean> |
CoordUtils.getCoordActions(String rangeType,
String jobId,
String scope,
boolean active)
Get the list of actions for a given coordinator job
|
static List<CoordinatorActionBean> |
CoordUtils.getCoordActionsFromIds(String jobId,
String scope)
Get the list of actions for given id ranges
|
| Modifier and Type | Method and Description |
|---|---|
static ELEvaluator |
CoordELEvaluator.createSLAEvaluator(org.jdom.Element eAction,
CoordinatorActionBean coordAction,
org.apache.hadoop.conf.Configuration conf)
Create a SLA evaluator to be used during Materialization
|
| Modifier and Type | Method and Description |
|---|---|
CoordinatorActionBean |
CoordActionGetForSLAJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordActionGetJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordJobGetActionForNominalTimeJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordActionGetForStartJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordActionGetForCheckJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordActionGetForInputCheckJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordActionGetForInfoJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordActionGetForExternalIdJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordActionGetForTimeoutJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordActionQueryExecutor.get(CoordActionQueryExecutor.CoordActionQuery namedQuery,
Object... parameters) |
| Modifier and Type | Method and Description |
|---|---|
List<CoordinatorActionBean> |
CoordJobGetActionsRunningJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordJobGetActionsForDatesJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordJobGetActionsByDatesForKillJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordJobGetActionsNotCompletedJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordActionsGetForRecoveryJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordJobGetActionsSubsetJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordJobGetActionsSuspendedJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordJobGetReadyActionsJPAExecutor.execute(javax.persistence.EntityManager em) |
static QueryExecutor<CoordinatorActionBean,CoordActionQueryExecutor.CoordActionQuery> |
CoordActionQueryExecutor.getInstance() |
List<CoordinatorActionBean> |
CoordActionQueryExecutor.getList(CoordActionQueryExecutor.CoordActionQuery namedQuery,
Object... parameters) |
| Modifier and Type | Method and Description |
|---|---|
int |
CoordActionQueryExecutor.executeUpdate(CoordActionQueryExecutor.CoordActionQuery namedQuery,
CoordinatorActionBean jobBean) |
javax.persistence.Query |
CoordActionQueryExecutor.getUpdateQuery(CoordActionQueryExecutor.CoordActionQuery namedQuery,
CoordinatorActionBean actionBean,
javax.persistence.EntityManager em) |
| Constructor and Description |
|---|
CoordActionInsertJPAExecutor(CoordinatorActionBean coordAction) |
| Modifier and Type | Method and Description |
|---|---|
static List<CoordinatorActionBean> |
CoordActionsInDateRange.getCoordActionsFromDateRange(String jobId,
String range,
boolean active)
Get the coordinator actions for a given date range
|
| Modifier and Type | Method and Description |
|---|---|
static void |
LogUtils.setLogInfo(CoordinatorActionBean action)
Set the thread local log info with the context of the given coordinator action bean.
|
Copyright © 2016 Apache Software Foundation. All Rights Reserved.