org.apache.oozie.service
Class RecoveryService

java.lang.Object
  extended by 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.


Copyright © 2013 Apache Software Foundation. All Rights Reserved.