org.apache.hcatalog.listener

Class NotificationListener

java.lang.Object

org.apache.hadoop.hive.metastore.MetaStoreEventListener

org.apache.hcatalog.listener.NotificationListener

Deprecated.

Use/modify NotificationListener instead

public class NotificationListener
extends MetaStoreEventListener

Implementation of MetaStoreEventListener It sends message on two type of topics. One has name of form dbName.tblName On this topic, two kind of messages are sent: add/drop partition and finalize_partition message. Second topic has name "HCAT" and messages sent on it are: add/drop database and add/drop table. All messages also has a property named "HCAT_EVENT" set on them whose value can be used to configure message selector on subscriber side.

Field Summary

Fields

Modifier and Type	Field and Description
protected javax.jms.Connection	conn Deprecated.
protected javax.jms.Session	session Deprecated.

Constructor Summary

Constructors

Constructor and Description
NotificationListener(Configuration conf) Deprecated. Create message bus connection and session in constructor.

Method Summary

Modifier and Type	Method and Description
protected void	createConnection() Deprecated.
protected void	finalize() Deprecated.
protected javax.jms.Topic	getTopic(java.lang.String topicName) Deprecated. Get the topic object for the topicName, it also tries to reconnect if the connection appears to be broken.
void	onAddPartition(AddPartitionEvent partitionEvent) Deprecated.
void	onAlterPartition(AlterPartitionEvent ape) Deprecated.
void	onAlterTable(AlterTableEvent ate) Deprecated.
void	onCreateDatabase(CreateDatabaseEvent dbEvent) Deprecated.
void	onCreateTable(CreateTableEvent tableEvent) Deprecated.
void	onDropDatabase(DropDatabaseEvent dbEvent) Deprecated.
void	onDropPartition(DropPartitionEvent partitionEvent) Deprecated. Send dropped partition notifications.
void	onDropTable(DropTableEvent tableEvent) Deprecated. Send dropped table notifications.
void	onLoadPartitionDone(LoadPartitionDoneEvent lpde) Deprecated.
protected void	send(HCatEventMessage hCatEventMessage, java.lang.String topicName) Deprecated.

Methods inherited from class org.apache.hadoop.hive.metastore.MetaStoreEventListener

getConf, setConf

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

session

protected javax.jms.Session session

Deprecated.

conn

protected javax.jms.Connection conn

Deprecated.

Constructor Detail

NotificationListener

public NotificationListener(Configuration conf)

Deprecated.

Create message bus connection and session in constructor.

Method Detail

onAddPartition

public void onAddPartition(AddPartitionEvent partitionEvent)
                    throws MetaException

Deprecated.

Overrides:

onAddPartition in class MetaStoreEventListener

Throws:

MetaException

onDropPartition

public void onDropPartition(DropPartitionEvent partitionEvent)
                     throws MetaException

Deprecated.

Send dropped partition notifications. Subscribers can receive these notifications for a particular table by listening on a topic named "dbName.tableName" with message selector string "HCAT_EVENT" = "DROP_PARTITION".
TODO: DataNucleus 2.0.3, currently used by the HiveMetaStore for persistence, has been found to throw NPE when serializing objects that contain null. For this reason we override some fields in the StorageDescriptor of this notification. This should be fixed after HIVE-2084 "Upgrade datanucleus from 2.0.3 to 3.0.1" is resolved.

Overrides:

onDropPartition in class MetaStoreEventListener

Parameters:

partitionEvent - partition event

Throws:

MetaException

onCreateDatabase

public void onCreateDatabase(CreateDatabaseEvent dbEvent)
                      throws MetaException

Deprecated.

Overrides:

onCreateDatabase in class MetaStoreEventListener

Parameters:

dbEvent - database event

Throws:

MetaException

onDropDatabase

public void onDropDatabase(DropDatabaseEvent dbEvent)
                    throws MetaException

Deprecated.

Overrides:

onDropDatabase in class MetaStoreEventListener

Parameters:

dbEvent - database event

Throws:

MetaException

onCreateTable

public void onCreateTable(CreateTableEvent tableEvent)
                   throws MetaException

Deprecated.

Overrides:

onCreateTable in class MetaStoreEventListener

Parameters:

tableEvent - table event.

Throws:

MetaException

onDropTable

public void onDropTable(DropTableEvent tableEvent)
                 throws MetaException

Deprecated.

Send dropped table notifications. Subscribers can receive these notifications for dropped tables by listening on topic "HCAT" with message selector string "HCAT_EVENT" = "DROP_TABLE"
TODO: DataNucleus 2.0.3, currently used by the HiveMetaStore for persistence, has been found to throw NPE when serializing objects that contain null. For this reason we override some fields in the StorageDescriptor of this notification. This should be fixed after HIVE-2084 "Upgrade datanucleus from 2.0.3 to 3.0.1" is resolved.

Overrides:

onDropTable in class MetaStoreEventListener

Parameters:

tableEvent - table event.

Throws:

MetaException

send

protected void send(HCatEventMessage hCatEventMessage,
                    java.lang.String topicName)

Deprecated.

Parameters:

hCatEventMessage - The HCatEventMessage being sent over JMS.

topicName - is the name on message broker on which message is sent.

getTopic

protected javax.jms.Topic getTopic(java.lang.String topicName)
                            throws javax.jms.JMSException

Deprecated.

Get the topic object for the topicName, it also tries to reconnect if the connection appears to be broken.

Parameters:

topicName - The String identifying the message-topic.

Returns:

A Topic object corresponding to the specified topicName.

Throws:

javax.jms.JMSException

createConnection

protected void createConnection()

Deprecated.

finalize

protected void finalize()
                 throws java.lang.Throwable

Deprecated.

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

onLoadPartitionDone

public void onLoadPartitionDone(LoadPartitionDoneEvent lpde)
                         throws MetaException

Deprecated.

Overrides:

onLoadPartitionDone in class MetaStoreEventListener

Throws:

MetaException

onAlterPartition

public void onAlterPartition(AlterPartitionEvent ape)
                      throws MetaException

Deprecated.

Overrides:

onAlterPartition in class MetaStoreEventListener

Parameters:

ape - partition event

Throws:

MetaException

onAlterTable

public void onAlterTable(AlterTableEvent ate)
                  throws MetaException

Deprecated.

Overrides:

onAlterTable in class MetaStoreEventListener

Parameters:

ate - alter table event

Throws:

MetaException