org.apache.oozie.service

Class RecoveryService

java.lang.Object

org.apache.oozie.service.RecoveryService

All Implemented Interfaces:

Service

public class RecoveryService
extends Object
implements Service

The Recovery Service checks for pending actions and premater coordinator jobs older than a configured age and then queues them for execution.

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONF_BUNDLE_OLDER_THAN Age of Bundle jobs to recover, in seconds.
static String	CONF_CALLABLE_BATCH_SIZE The number of callables to be queued in a batch.
static String	CONF_COORD_OLDER_THAN Age of coordinator jobs to recover, in seconds.
static String	CONF_PREFIX_BUNDLE
static String	CONF_PREFIX_COORD
static String	CONF_PREFIX_WF_ACTIONS
static String	CONF_PUSH_DEPENDENCY_INTERVAL Delay for the push missing dependencies in milliseconds.
static String	CONF_SERVICE_INTERVAL Time interval, in seconds, at which the recovery service will be scheduled to run.
static String	CONF_WF_ACTIONS_CREATED_TIME_INTERVAL
static String	CONF_WF_ACTIONS_OLDER_THAN Age of actions to queue, in seconds.
static long	ONE_DAY_MILLISCONDS
static String	RECOVERY_SERVICE_CONF_PREFIX

Fields inherited from interface org.apache.oozie.service.Service

CONF_PREFIX, DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
RecoveryService()

Method Summary

Modifier and Type	Method and Description
void	destroy() Destroy the Recovery Service.
Class<? extends Service>	getInterface() Return the public interface for the Recovery Service.
int	getRecoveryServiceInterval(org.apache.hadoop.conf.Configuration conf)
void	init(Services services) Initializes the RecoveryService.

Methods inherited from class java.lang.Object

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

Field Detail

RECOVERY_SERVICE_CONF_PREFIX

public static final String RECOVERY_SERVICE_CONF_PREFIX

See Also:

Constant Field Values

CONF_PREFIX_WF_ACTIONS

public static final String CONF_PREFIX_WF_ACTIONS

See Also:

Constant Field Values

CONF_PREFIX_COORD

public static final String CONF_PREFIX_COORD

See Also:

Constant Field Values

CONF_PREFIX_BUNDLE

public static final String CONF_PREFIX_BUNDLE

See Also:

Constant Field Values

CONF_SERVICE_INTERVAL

public static final String CONF_SERVICE_INTERVAL

Time interval, in seconds, at which the recovery service will be scheduled to run.

See Also:

Constant Field Values

CONF_CALLABLE_BATCH_SIZE

public static final String CONF_CALLABLE_BATCH_SIZE

The number of callables to be queued in a batch.

See Also:

Constant Field Values

CONF_PUSH_DEPENDENCY_INTERVAL

public static final String CONF_PUSH_DEPENDENCY_INTERVAL

Delay for the push missing dependencies in milliseconds.

See Also:

Constant Field Values

CONF_WF_ACTIONS_OLDER_THAN

public static final String CONF_WF_ACTIONS_OLDER_THAN

Age of actions to queue, in seconds.

See Also:

Constant Field Values

CONF_WF_ACTIONS_CREATED_TIME_INTERVAL

public static final String CONF_WF_ACTIONS_CREATED_TIME_INTERVAL

See Also:

Constant Field Values

CONF_COORD_OLDER_THAN

public static final String CONF_COORD_OLDER_THAN

Age of coordinator jobs to recover, in seconds.

See Also:

Constant Field Values

CONF_BUNDLE_OLDER_THAN

public static final String CONF_BUNDLE_OLDER_THAN

Age of Bundle jobs to recover, in seconds.

See Also:

Constant Field Values

ONE_DAY_MILLISCONDS

public static final long ONE_DAY_MILLISCONDS

See Also:

Constant Field Values

Constructor Detail

RecoveryService

public RecoveryService()

Method Detail

init

public void init(Services services)

Initializes the RecoveryService.

Specified by:

init in interface Service

Parameters:

services - services instance.

getRecoveryServiceInterval

public int getRecoveryServiceInterval(org.apache.hadoop.conf.Configuration conf)

destroy

public void destroy()

Destroy the Recovery Service.

Specified by:

destroy in interface Service

getInterface

public Class<? extends Service> getInterface()

Return the public interface for the Recovery Service.

Specified by:

getInterface in interface Service

Returns:

RecoveryService.