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_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_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.
 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

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_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_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.

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.


Copyright © 2013 Apache Software Foundation. All Rights Reserved.