org.apache.oozie.coord

Class CoordUtils

java.lang.Object

org.apache.oozie.coord.CoordUtils

public class CoordUtils
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	HADOOP_USER

Constructor Summary

Constructors

Constructor and Description
CoordUtils()

Method Summary

Methods

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

HADOOP_USER

public static final String HADOOP_USER

See Also:

Constant Field Values

Constructor Detail

CoordUtils

public CoordUtils()

Method Detail

getDoneFlag

public static String getDoneFlag(org.jdom.Element doneFlagElement)

getHadoopConf

public static org.apache.hadoop.conf.Configuration getHadoopConf(org.apache.hadoop.conf.Configuration jobConf)

getCoordActions

public static List<CoordinatorActionBean> getCoordActions(String rangeType,
                                          String jobId,
                                          String scope,
                                          boolean active)
                                                   throws CommandException

Get the list of actions for a given coordinator job

Parameters:

rangeType - the rerun type (date, action)

jobId - the coordinator job id

scope - the date scope or action id scope

Returns:

the list of Coordinator actions

Throws:

CommandException

getCoordActionsFromDates

public static List<CoordinatorActionBean> getCoordActionsFromDates(String jobId,
                                                   String scope,
                                                   boolean active)
                                                            throws CommandException

Get the list of actions for given date ranges

Parameters:

jobId - coordinator job id

scope - a comma-separated list of date ranges. Each date range element is specified with two dates separated by '::'

Returns:

the list of Coordinator actions for the date range

Throws:

CommandException - thrown if failed to get coordinator actions by given date range

getActionsIds

public static Set<String> getActionsIds(String jobId,
                        String scope)
                                 throws CommandException

Throws:

CommandException

getCoordActionsFromIds

public static List<CoordinatorActionBean> getCoordActionsFromIds(String jobId,
                                                 String scope)
                                                          throws CommandException

Get the list of actions for given id ranges

Parameters:

jobId - coordinator job id

scope - a comma-separated list of action ranges. The action range is specified with two action numbers separated by '-'

Returns:

the list of all Coordinator actions for action range

Throws:

CommandException - thrown if failed to get coordinator actions by given id range

isSlaAlertDisabled

public static boolean isSlaAlertDisabled(CoordinatorActionBean actionBean,
                         String coordName,
                         org.apache.hadoop.conf.Configuration jobConf)
                                  throws ParseException

Check if sla alert is disabled for action.

Parameters:

actionBean -

coordName -

jobConf -

Returns:

Throws:

ParseException

getWhereClause

public static Map<String,Object> getWhereClause(StringBuilder sb,
                                Map<Pair<String,CoordinatorEngine.FILTER_COMPARATORS>,List<Object>> filterMap)

isInputLogicSpecified

public static boolean isInputLogicSpecified(String actionXml)
                                     throws org.jdom.JDOMException

Throws:

org.jdom.JDOMException

isInputLogicSpecified

public static boolean isInputLogicSpecified(org.jdom.Element eAction)
                                     throws org.jdom.JDOMException

Throws:

org.jdom.JDOMException

getInputLogic

public static String getInputLogic(String actionXml)
                            throws org.jdom.JDOMException

Throws:

org.jdom.JDOMException

getInputLogic

public static String getInputLogic(org.jdom.Element actionXml)
                            throws org.jdom.JDOMException

Throws:

org.jdom.JDOMException