This project has retired. For details please refer to its Attic page.

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

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
static String	CONF_PREFIX_BUNDLE
static String	CONF_PREFIX_COORD
static String	CONF_PREFIX_WF_ACTIONS
static String	CONF_SERVICE_INTERVAL Time interval, in seconds, at which the recovery service will be scheduled to run.
static String	CONF_WF_ACTIONS_OLDER_THAN Age of actions to queue, in seconds.

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

DEFAULT_LOCK_TIMEOUT, lockTimeout, USE_XCOMMAND

Constructor Summary

RecoveryService()

Method Summary

void	destroy() Destroy the Recovery Service.
Class<? extends Service>	getInterface() Return the public interface for the Recovery Service.
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

CONF_PREFIX

public static final String 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_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_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

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.

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.