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 List<CoordinatorActionBean>	getCoordActions(String rangeType, String jobId, String scope, boolean active) Get the list of actions for a given coordinator job
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 Map<String,Object>	getWhereClause(StringBuilder sb, Map<Pair<String,CoordinatorEngine.FILTER_COMPARATORS>,List<Object>> filterMap)

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

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

getWhereClause

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