org.apache.oozie.coord

Class CoordUtils

java.lang.Object

org.apache.oozie.coord.CoordUtils

public class CoordUtils
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	HADOOP_USER

Constructor Summary

Constructors

Constructor and Description
CoordUtils()

Method Summary

Methods

Modifier and Type	Method and Description
static java.util.List<CoordinatorActionBean>	getCoordActions(java.lang.String rangeType, java.lang.String jobId, java.lang.String scope, boolean active) Get the list of actions for a given coordinator job
static java.util.List<CoordinatorActionBean>	getCoordActionsFromIds(java.lang.String jobId, java.lang.String scope) Get the list of actions for given id ranges
static java.lang.String	getDoneFlag(org.jdom.Element doneFlagElement)
static org.apache.hadoop.conf.Configuration	getHadoopConf(org.apache.hadoop.conf.Configuration jobConf)
static java.util.Map<java.lang.String,java.lang.Object>	getWhereClause(java.lang.StringBuilder sb, java.util.Map<Pair<java.lang.String,CoordinatorEngine.FILTER_COMPARATORS>,java.util.List<java.lang.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 java.lang.String HADOOP_USER

See Also:

Constant Field Values

Constructor Detail

CoordUtils

public CoordUtils()

Method Detail

getDoneFlag

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

getHadoopConf

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

getCoordActions

public static java.util.List<CoordinatorActionBean> getCoordActions(java.lang.String rangeType,
                                                    java.lang.String jobId,
                                                    java.lang.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 java.util.List<CoordinatorActionBean> getCoordActionsFromIds(java.lang.String jobId,
                                                           java.lang.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 java.util.Map<java.lang.String,java.lang.Object> getWhereClause(java.lang.StringBuilder sb,
                                                              java.util.Map<Pair<java.lang.String,CoordinatorEngine.FILTER_COMPARATORS>,java.util.List<java.lang.Object>> filterMap)