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 | Method and Description |
---|---|
protected void |
Command.setLogInfo(CoordinatorActionBean action)
Set the log info with the context of the given coordinator action bean.
|
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 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 |
CoordJobGetActionForNominalTimeJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordActionGetJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordActionGetForTimeoutJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordActionGetForStartJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordActionGetForSLAJPAExecutor.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 |
CoordActionGetForCheckJPAExecutor.execute(javax.persistence.EntityManager em) |
CoordinatorActionBean |
CoordActionQueryExecutor.get(CoordActionQueryExecutor.CoordActionQuery namedQuery,
Object... parameters) |
Modifier and Type | Method and Description |
---|---|
List<CoordinatorActionBean> |
CoordJobGetReadyActionsJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordJobGetActionsSuspendedJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordJobGetActionsSubsetJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordJobGetActionsRunningJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordJobGetActionsNotCompletedJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordJobGetActionsForDatesJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordJobGetActionsByDatesForKillJPAExecutor.execute(javax.persistence.EntityManager em) |
List<CoordinatorActionBean> |
CoordActionsGetForRecoveryJPAExecutor.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 |
---|---|
CoordinatorActionBean |
CoordinatorStore.getAction(String id,
boolean b) |
protected CoordinatorActionBean |
CoordinatorStore.getBeanForRunningCoordAction(CoordinatorActionBean a) |
CoordinatorActionBean |
CoordinatorStore.getCoordActionForNominalTime(String jobId,
Date nominalTime)
Get coordinator action bean for given date
|
CoordinatorActionBean |
CoordinatorStore.getCoordinatorAction(String id,
boolean locking)
Load the CoordinatorAction into a Bean and return it.
|
Modifier and Type | Method and Description |
---|---|
List<CoordinatorActionBean> |
CoordinatorStore.getActionsSubsetForCoordinatorJob(String jobId,
int start,
int len)
Loads given number of actions for the given Coordinator job.
|
List<CoordinatorActionBean> |
CoordinatorStore.getCoordActionsForDates(String jobId,
Date startDate,
Date endDate)
Get coordinator action beans for given start date and end date
|
List<CoordinatorActionBean> |
CoordinatorStore.getCoordinatorActionsForJob(String id,
int numResults,
String executionOrder)
Return CoordinatorActions for a jobID.
|
List<CoordinatorActionBean> |
CoordinatorStore.getRecoveryActionsOlderThan(long checkAgeSecs,
boolean locking) |
List<CoordinatorActionBean> |
CoordinatorStore.getRunningActionsForCoordinatorJob(String jobId,
boolean locking) |
List<CoordinatorActionBean> |
CoordinatorStore.getRunningActionsOlderThan(long checkAgeSecs,
boolean locking) |
Modifier and Type | Method and Description |
---|---|
protected CoordinatorActionBean |
CoordinatorStore.getBeanForRunningCoordAction(CoordinatorActionBean a) |
void |
CoordinatorStore.insertCoordinatorAction(CoordinatorActionBean action)
Create a new Action record in the ACTIONS table with the given Bean.
|
void |
CoordinatorStore.updateCoordActionMin(CoordinatorActionBean action)
Update the given action bean to DB.
|
void |
CoordinatorStore.updateCoordinatorAction(CoordinatorActionBean action)
Update the given action bean to DB.
|
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,
XLog.Info logInfo)
Set the log info with the context of the given coordinator action bean.
|
Copyright © 2014 Apache Software Foundation. All Rights Reserved.