org.apache.oozie.service

Class HCatAccessorService

java.lang.Object

org.apache.oozie.service.HCatAccessorService

All Implemented Interfaces:

Service

public class HCatAccessorService
extends Object
implements Service

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONF_PREFIX
static String	HCAT_CONFIGURATION
static String	JMS_CONNECTIONS_PROPERTIES

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

DEFAULT_LOCK_TIMEOUT, lockTimeout

Constructor Summary

Constructors

Constructor and Description
HCatAccessorService()

Method Summary

Methods

Modifier and Type	Method and Description
void	destroy() Destroy the service.
org.apache.hadoop.conf.Configuration	getHCatConf()
Class<? extends Service>	getInterface() Return the public interface of the service.
JMSConnectionInfo	getJMSConnectionInfo(URI publisherURI) Given a publisher host:port return the connection details of JMS server that the publisher publishes to
void	init(Services services) Initialize the service.
boolean	isKnownPublisher(URI sourceURI) Determine whether a given source URI publishes JMS messages
boolean	isRegisteredForNotification(HCatURI hcatURI) Check if we are already listening to the JMS topic for the table in the given hcatURI
void	registerForNotification(HCatURI hcatURI, String topic, HCatMessageHandler msgHandler) Register for notifications on a JMS topic for the specified hcatalog table.
void	unregisterFromNotification(HCatURI hcatURI)
void	unregisterFromNotification(String server, String database, String table)

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

JMS_CONNECTIONS_PROPERTIES

public static final String JMS_CONNECTIONS_PROPERTIES

See Also:

Constant Field Values

HCAT_CONFIGURATION

public static final String HCAT_CONFIGURATION

See Also:

Constant Field Values

Constructor Detail

HCatAccessorService

public HCatAccessorService()

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.

getHCatConf

public org.apache.hadoop.conf.Configuration getHCatConf()

isKnownPublisher

public boolean isKnownPublisher(URI sourceURI)

Determine whether a given source URI publishes JMS messages

Parameters:

sourceURI - URI of the publisher

Returns:

true if we have JMS connection information for the source URI, else false

getJMSConnectionInfo

public JMSConnectionInfo getJMSConnectionInfo(URI publisherURI)

Given a publisher host:port return the connection details of JMS server that the publisher publishes to

Parameters:

publisherURI - URI of the publisher

Returns:

JMSConnectionInfo to connect to the JMS server that the publisher publishes to

isRegisteredForNotification

public boolean isRegisteredForNotification(HCatURI hcatURI)

Check if we are already listening to the JMS topic for the table in the given hcatURI

Parameters:

hcatURI - hcatalog partition URI

Returns:

true if registered to a JMS topic for the table in the given hcatURI

registerForNotification

public void registerForNotification(HCatURI hcatURI,
                           String topic,
                           HCatMessageHandler msgHandler)

Register for notifications on a JMS topic for the specified hcatalog table.

Parameters:

hcatURI - hcatalog partition URI

topic - JMS topic to register to

msgHandler - Handler which will process the messages received on the topic

unregisterFromNotification

public void unregisterFromNotification(HCatURI hcatURI)

unregisterFromNotification

public void unregisterFromNotification(String server,
                              String database,
                              String table)

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.