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 |
---|---|
protected boolean |
CoordActionInputCheckXCommand.checkUnResolvedInput(CoordinatorActionBean coordAction,
StringBuilder actionXml,
org.apache.hadoop.conf.Configuration conf)
Check un resolved input.
|
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 void |
CoordCommandUtils.materializeInputDataEvents(List<org.jdom.Element> events,
SyncCoordAction appInst,
org.apache.hadoop.conf.Configuration conf,
CoordinatorActionBean actionBean,
boolean isInputLogicSpecified) |
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 |
---|---|
protected void |
SLACoordActionJobHistoryXCommand.updateSLASummaryForCoordAction(CoordinatorActionBean bean) |
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.getCoordActionsFromDates(String jobId,
String scope,
boolean active)
Get the list of actions for given date ranges
|
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
|
static boolean |
CoordUtils.isSlaAlertDisabled(CoordinatorActionBean actionBean,
String coordName,
org.apache.hadoop.conf.Configuration jobConf)
Check if sla alert is disabled for action.
|
Modifier and Type | Method and Description |
---|---|
boolean |
CoordOldInputDependency.checkPullMissingDependencies(CoordinatorActionBean coordAction,
StringBuilder existList,
StringBuilder nonExistList) |
boolean |
CoordInputDependency.checkPullMissingDependencies(CoordinatorActionBean coordAction,
StringBuilder existList,
StringBuilder nonExistList)
Check pull missing dependencies.
|
boolean |
AbstractCoordInputDependency.checkPullMissingDependencies(CoordinatorActionBean coordAction,
StringBuilder existList,
StringBuilder nonExistList) |
ActionDependency |
CoordOldInputDependency.checkPushMissingDependencies(CoordinatorActionBean coordAction,
boolean registerForNotification) |
ActionDependency |
CoordInputDependency.checkPushMissingDependencies(CoordinatorActionBean coordAction,
boolean registerForNotification)
Check push missing dependencies.
|
ActionDependency |
AbstractCoordInputDependency.checkPushMissingDependencies(CoordinatorActionBean coordAction,
boolean registerForNotification) |
boolean |
CoordOldInputDependency.checkUnresolved(CoordinatorActionBean coordAction,
org.jdom.Element eAction) |
boolean |
CoordInputDependency.checkUnresolved(CoordinatorActionBean coordAction,
org.jdom.Element eAction)
Check unresolved.
|
boolean |
AbstractCoordInputDependency.checkUnresolved(CoordinatorActionBean coordAction,
org.jdom.Element eAction) |
boolean |
CoordOldInputDependency.pathExists(CoordinatorActionBean coordAction,
String sPath,
org.apache.hadoop.conf.Configuration actionConf,
String user) |
Modifier and Type | Field and Description |
---|---|
protected CoordinatorActionBean |
CoordInputLogicEvaluatorPhaseValidate.coordAction |
protected CoordinatorActionBean |
CoordInputLogicEvaluatorPhaseOne.coordAction |
Modifier and Type | Method and Description |
---|---|
CoordInputLogicEvaluatorResult |
CoordInputLogicEvaluatorPhaseOne.getResultFromPullPush(CoordinatorActionBean coordAction,
String dataSet,
int min) |
Constructor and Description |
---|
CoordInputLogicEvaluatorPhaseOne(CoordinatorActionBean coordAction) |
CoordInputLogicEvaluatorPhaseOne(CoordinatorActionBean coordAction,
CoordInputDependency coordInputDependency) |
CoordInputLogicEvaluatorPhaseThree(CoordinatorActionBean coordAction,
ELEvaluator eval) |
CoordInputLogicEvaluatorPhaseTwo(CoordinatorActionBean coordAction,
AbstractCoordInputDependency coordInputDependency) |
CoordInputLogicEvaluatorPhaseTwo(CoordinatorActionBean coordAction,
Date actualTime) |
CoordInputLogicEvaluatorPhaseValidate(CoordinatorActionBean coordAction) |
CoordInputLogicEvaluatorUtil(CoordinatorActionBean coordAction) |
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 |
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) |
CoordinatorActionBean |
CoordActionQueryExecutor.getIfExist(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) |
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.