public class CoordUtils extends Object
Modifier and Type | Field and Description |
---|---|
static String |
HADOOP_USER |
Constructor and Description |
---|
CoordUtils() |
Modifier and Type | Method and Description |
---|---|
static Set<String> |
getActionsIds(String jobId,
String scope) |
static List<CoordinatorActionBean> |
getCoordActions(String rangeType,
String jobId,
String scope,
boolean active)
Get the list of actions for a given coordinator job
|
static List<CoordinatorActionBean> |
getCoordActionsFromDates(String jobId,
String scope,
boolean active)
Get the list of actions for given date ranges
|
static List<CoordinatorActionBean> |
getCoordActionsFromIds(String jobId,
String scope)
Get the list of actions for given id ranges
|
static String |
getDoneFlag(org.jdom.Element doneFlagElement) |
static org.apache.hadoop.conf.Configuration |
getHadoopConf(org.apache.hadoop.conf.Configuration jobConf) |
static String |
getInputLogic(org.jdom.Element actionXml) |
static String |
getInputLogic(String actionXml) |
static Map<String,Object> |
getWhereClause(StringBuilder sb,
Map<Pair<String,CoordinatorEngine.FILTER_COMPARATORS>,List<Object>> filterMap) |
static boolean |
isInputLogicSpecified(org.jdom.Element eAction) |
static boolean |
isInputLogicSpecified(String actionXml) |
static boolean |
isSlaAlertDisabled(CoordinatorActionBean actionBean,
String coordName,
org.apache.hadoop.conf.Configuration jobConf)
Check if sla alert is disabled for action.
|
public static final String HADOOP_USER
public CoordUtils()
public static String getDoneFlag(org.jdom.Element doneFlagElement)
public static org.apache.hadoop.conf.Configuration getHadoopConf(org.apache.hadoop.conf.Configuration jobConf)
public static List<CoordinatorActionBean> getCoordActions(String rangeType, String jobId, String scope, boolean active) throws CommandException
rangeType
- the rerun type (date, action)jobId
- the coordinator job idscope
- the date scope or action id scopeCommandException
public static List<CoordinatorActionBean> getCoordActionsFromDates(String jobId, String scope, boolean active) throws CommandException
jobId
- coordinator job idscope
- a comma-separated list of date ranges. Each date range element is specified with two dates separated by '::'CommandException
- thrown if failed to get coordinator actions by given date rangepublic static Set<String> getActionsIds(String jobId, String scope) throws CommandException
CommandException
public static List<CoordinatorActionBean> getCoordActionsFromIds(String jobId, String scope) throws CommandException
jobId
- coordinator job idscope
- a comma-separated list of action ranges. The action range is specified with two action numbers separated by '-'CommandException
- thrown if failed to get coordinator actions by given id rangepublic static boolean isSlaAlertDisabled(CoordinatorActionBean actionBean, String coordName, org.apache.hadoop.conf.Configuration jobConf) throws ParseException
actionBean
- coordName
- jobConf
- ParseException
public static Map<String,Object> getWhereClause(StringBuilder sb, Map<Pair<String,CoordinatorEngine.FILTER_COMPARATORS>,List<Object>> filterMap)
public static boolean isInputLogicSpecified(String actionXml) throws org.jdom.JDOMException
org.jdom.JDOMException
public static boolean isInputLogicSpecified(org.jdom.Element eAction) throws org.jdom.JDOMException
org.jdom.JDOMException
public static String getInputLogic(String actionXml) throws org.jdom.JDOMException
org.jdom.JDOMException
public static String getInputLogic(org.jdom.Element actionXml) throws org.jdom.JDOMException
org.jdom.JDOMException
Copyright © 2018 Apache Software Foundation. All rights reserved.