org.apache.oozie.service

Class ActionCheckerService

java.lang.Object

org.apache.oozie.service.ActionCheckerService

All Implemented Interfaces:

Service

public class ActionCheckerService
extends java.lang.Object
implements Service

The Action Checker Service queue ActionCheckCommands to check the status of running actions and CoordActionCheckCommands to check the status of coordinator actions. The delay between checks on the same action can be configured.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CONF_ACTION_CHECK_DELAY The time, in seconds, between an ActionCheck for the same action.
static java.lang.String	CONF_ACTION_CHECK_INTERVAL The frequency at which the ActionCheckService will run.
static java.lang.String	CONF_CALLABLE_BATCH_SIZE The number of callables to be queued in a batch.
static java.lang.String	CONF_PREFIX
protected static java.lang.String	INSTR_CHECK_ACTIONS_COUNTER
protected static java.lang.String	INSTR_CHECK_COORD_ACTIONS_COUNTER
protected static java.lang.String	INSTRUMENTATION_GROUP

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

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
ActionCheckerService()

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy() Destroy the Action Checker Services.
java.lang.Class<? extends Service>	getInterface() Return the public interface for the action checker service.
void	init(Services services) Initializes the Action Check service.

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 java.lang.String CONF_PREFIX

See Also:

Constant Field Values

CONF_ACTION_CHECK_INTERVAL

public static final java.lang.String CONF_ACTION_CHECK_INTERVAL

The frequency at which the ActionCheckService will run.

See Also:

Constant Field Values

CONF_ACTION_CHECK_DELAY

public static final java.lang.String CONF_ACTION_CHECK_DELAY

The time, in seconds, between an ActionCheck for the same action.

See Also:

Constant Field Values

CONF_CALLABLE_BATCH_SIZE

public static final java.lang.String CONF_CALLABLE_BATCH_SIZE

The number of callables to be queued in a batch.

See Also:

Constant Field Values

INSTRUMENTATION_GROUP

protected static final java.lang.String INSTRUMENTATION_GROUP

See Also:

Constant Field Values

INSTR_CHECK_ACTIONS_COUNTER

protected static final java.lang.String INSTR_CHECK_ACTIONS_COUNTER

See Also:

Constant Field Values

INSTR_CHECK_COORD_ACTIONS_COUNTER

protected static final java.lang.String INSTR_CHECK_COORD_ACTIONS_COUNTER

See Also:

Constant Field Values

Constructor Detail

ActionCheckerService

public ActionCheckerService()

Method Detail

init

public void init(Services services)

Initializes the Action Check service.

Specified by:

init in interface Service

Parameters:

services - services instance.

destroy

public void destroy()

Destroy the Action Checker Services.

Specified by:

destroy in interface Service

getInterface

public java.lang.Class<? extends Service> getInterface()

Return the public interface for the action checker service.

Specified by:

getInterface in interface Service

Returns:

ActionCheckerService.