org.apache.oozie.service

Class CoordMaterializeTriggerService

java.lang.Object

org.apache.oozie.service.CoordMaterializeTriggerService

All Implemented Interfaces:

Service

public class CoordMaterializeTriggerService
extends Object
implements Service

The coordinator Materialization Lookup trigger service schedule lookup trigger command for every interval (default is 5 minutes ). This interval could be configured through oozie configuration defined is either oozie-default.xml or oozie-site.xml using the property name oozie.service.CoordMaterializeTriggerService.lookup.interval

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONF_CALLABLE_BATCH_SIZE The number of callables to be queued in a batch.
static String	CONF_LOOKUP_INTERVAL Time interval, in seconds, at which the Job materialization service will be scheduled to run.
static String	CONF_MATERIALIZATION_SYSTEM_LIMIT The number of coordinator jobs to be picked for materialization at a given time.
static String	CONF_MATERIALIZATION_WINDOW This configuration defined the duration for which job should be materialized in future
static String	CONF_PREFIX
static String	CONF_SCHEDULING_INTERVAL

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

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
CoordMaterializeTriggerService()

Method Summary

Modifier and Type	Method and Description
void	destroy() Destroy the service.
Class<? extends Service>	getInterface() Return the public interface of the service.
void	init(Services services) Initialize the 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 String CONF_PREFIX

See Also:

Constant Field Values

CONF_LOOKUP_INTERVAL

public static final String CONF_LOOKUP_INTERVAL

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

See Also:

Constant Field Values

CONF_SCHEDULING_INTERVAL

public static final String CONF_SCHEDULING_INTERVAL

See Also:

Constant Field Values

CONF_MATERIALIZATION_WINDOW

public static final String CONF_MATERIALIZATION_WINDOW

This configuration defined the duration for which job should be materialized in future

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_MATERIALIZATION_SYSTEM_LIMIT

public static final String CONF_MATERIALIZATION_SYSTEM_LIMIT

The number of coordinator jobs to be picked for materialization at a given time.

See Also:

Constant Field Values

Constructor Detail

CoordMaterializeTriggerService

public CoordMaterializeTriggerService()

Method Detail

init

public void init(Services services)
          throws ServiceException

Description copied from interface: Service

Initialize the service.

Invoked by the Service singleton at start up time.

Specified by:

init in interface Service

Parameters:

services - services singleton initializing the service.

Throws:

ServiceException - thrown if the service could not initialize.

destroy

public void destroy()

Description copied from interface: Service

Destroy the service.

Invoked by the Service singleton at shutdown time.

Specified by:

destroy in interface Service

getInterface

public Class<? extends Service> getInterface()

Description copied from interface: Service

Return the public interface of the service.

Services are retrieved by its public interface. Specializations of services must return the public interface.

Specified by:

getInterface in interface Service

Returns:

the interface of the service.