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 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) |
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> 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 rangeCopyright © 2014 Apache Software Foundation. All Rights Reserved.