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)

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