org.apache.oozie.util

Class CoordActionsInDateRange

java.lang.Object

org.apache.oozie.util.CoordActionsInDateRange

public class CoordActionsInDateRange
extends Object

This class provides the utility of listing coordinator actions that were executed between a certain date range. This is helpful in turn for retrieving the required logs in that date range.

Constructor Summary

Constructors

Constructor and Description
CoordActionsInDateRange()

Method Summary

Modifier and Type	Method and Description
static List<String>	getCoordActionIdsFromDateRange(String jobId, String range) Get the coordinator actions for a given date range
static List<String>	getCoordActionIdsFromDates(String jobId, String scope) Get the list of Coordinator action Ids for given date ranges
static List<CoordinatorActionBean>	getCoordActionsFromDateRange(String jobId, String range, boolean active) Get the coordinator actions for a given date range
static Date	getCoordActionsLastModifiedDate(String jobId, String startAction, String endAction) Gets the coordinator actions last modified date for range, if any action is running it return new date

Methods inherited from class java.lang.Object

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

Constructor Detail

CoordActionsInDateRange

public CoordActionsInDateRange()

Method Detail

getCoordActionIdsFromDates

public static List<String> getCoordActionIdsFromDates(String jobId,
                                                      String scope)
                                               throws XException

Get the list of Coordinator action Ids for given date ranges

Parameters:

jobId - coordinator job id

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

Returns:

the list of coordinator action Ids for the date range

Throws:

XException - if the scope is not well formatted Internally involves a database operation by invoking method 'getActionIdsFromDateRange'.

getCoordActionsFromDateRange

public static List<CoordinatorActionBean> getCoordActionsFromDateRange(String jobId,
                                                                       String range,
                                                                       boolean active)
                                                                throws XException

Get the coordinator actions for a given date range

Parameters:

jobId - the coordinator job id

range - the date range separated by '::'

active - to list only active (non-terminated) actions

Returns:

the list of Coordinator actions for the date range

Throws:

XException - if range is not well formatted or invalid

getCoordActionIdsFromDateRange

public static List<String> getCoordActionIdsFromDateRange(String jobId,
                                                          String range)
                                                   throws XException

Get the coordinator actions for a given date range

Parameters:

jobId - the coordinator job id

range - the date range separated by '::'

Returns:

the list of Coordinator actions for the date range

Throws:

XException - if range is not well formatted or invalid

getCoordActionsLastModifiedDate

public static Date getCoordActionsLastModifiedDate(String jobId,
                                                   String startAction,
                                                   String endAction)
                                            throws CommandException

Gets the coordinator actions last modified date for range, if any action is running it return new date

Parameters:

jobId - the job id

startAction - the start action

endAction - the end action

Returns:

the coordinator actions last modified date

Throws:

CommandException - the command exception