org.apache.oozie.service
Class CoordMaterializeTriggerService

java.lang.Object
  extended by 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
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
           
 
Fields inherited from interface org.apache.oozie.service.Service
DEFAULT_LOCK_TIMEOUT, lockTimeout, USE_XCOMMAND
 
Constructor Summary
CoordMaterializeTriggerService()
           
 
Method Summary
 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_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.


Copyright © 2012 Apache Software Foundation. All Rights Reserved.