org.apache.hive.hcatalog.listener

Class DbNotificationListener

java.lang.Object

org.apache.hadoop.hive.metastore.MetaStoreEventListener

org.apache.hive.hcatalog.listener.DbNotificationListener

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

public class DbNotificationListener
extends MetaStoreEventListener

An implementation of MetaStoreEventListener that stores events in the database. Design overview: This listener takes any event, builds a NotificationEventResponse, and puts it on a queue. There is a dedicated thread that reads entries from the queue and places them in the database. The reason for doing it in a separate thread is that we want to avoid slowing down other metadata operations with the work of putting the notification into the database. Also, occasionally the thread needs to clean the database of old records. We definitely don't want to do that as part of another metadata operation.

Constructor Summary

Constructors

Constructor and Description
DbNotificationListener(org.apache.hadoop.conf.Configuration config)

Method Summary

Modifier and Type	Method and Description
void	onAddPartition(AddPartitionEvent partitionEvent)
void	onAlterPartition(AlterPartitionEvent partitionEvent)
void	onAlterTable(AlterTableEvent tableEvent)
void	onConfigChange(ConfigChangeEvent tableEvent)
void	onCreateDatabase(CreateDatabaseEvent dbEvent)
void	onCreateTable(CreateTableEvent tableEvent)
void	onDropDatabase(DropDatabaseEvent dbEvent)
void	onDropPartition(DropPartitionEvent partitionEvent)
void	onDropTable(DropTableEvent tableEvent)
void	onInsert(InsertEvent insertEvent) This will be called when an insert is executed that does not cause a partition to be added.
void	onLoadPartitionDone(LoadPartitionDoneEvent partSetDoneEvent)

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

getConf, onAddIndex, onAlterIndex, onDropIndex, setConf

Methods inherited from class java.lang.Object

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

Constructor Detail

DbNotificationListener

public DbNotificationListener(org.apache.hadoop.conf.Configuration config)

Method Detail

onConfigChange

public void onConfigChange(ConfigChangeEvent tableEvent)
                    throws MetaException

Overrides:

onConfigChange in class MetaStoreEventListener

Parameters:

tableEvent - table event.

Throws:

MetaException

onCreateTable

public void onCreateTable(CreateTableEvent tableEvent)
                   throws MetaException

Overrides:

onCreateTable in class MetaStoreEventListener

Parameters:

tableEvent - table event.

Throws:

MetaException

onDropTable

public void onDropTable(DropTableEvent tableEvent)
                 throws MetaException

Overrides:

onDropTable in class MetaStoreEventListener

Parameters:

tableEvent - table event.

Throws:

MetaException

onAlterTable

public void onAlterTable(AlterTableEvent tableEvent)
                  throws MetaException

Overrides:

onAlterTable in class MetaStoreEventListener

Parameters:

tableEvent - alter table event

Throws:

MetaException

onAddPartition

public void onAddPartition(AddPartitionEvent partitionEvent)
                    throws MetaException

Overrides:

onAddPartition in class MetaStoreEventListener

Parameters:

partitionEvent - partition event

Throws:

MetaException

onDropPartition

public void onDropPartition(DropPartitionEvent partitionEvent)
                     throws MetaException

Overrides:

onDropPartition in class MetaStoreEventListener

Parameters:

partitionEvent - partition event

Throws:

MetaException

onAlterPartition

public void onAlterPartition(AlterPartitionEvent partitionEvent)
                      throws MetaException

Overrides:

onAlterPartition in class MetaStoreEventListener

Parameters:

partitionEvent - partition event

Throws:

MetaException

onCreateDatabase

public void onCreateDatabase(CreateDatabaseEvent dbEvent)
                      throws MetaException

Overrides:

onCreateDatabase in class MetaStoreEventListener

Parameters:

dbEvent - database event

Throws:

MetaException

onDropDatabase

public void onDropDatabase(DropDatabaseEvent dbEvent)
                    throws MetaException

Overrides:

onDropDatabase in class MetaStoreEventListener

Parameters:

dbEvent - database event

Throws:

MetaException

onInsert

public void onInsert(InsertEvent insertEvent)
              throws MetaException

Description copied from class: MetaStoreEventListener

This will be called when an insert is executed that does not cause a partition to be added. If an insert causes a partition to be added it will cause MetaStoreEventListener.onAddPartition(org.apache.hadoop.hive.metastore.events.AddPartitionEvent) to be called instead.

Overrides:

onInsert in class MetaStoreEventListener

Throws:

MetaException

onLoadPartitionDone

public void onLoadPartitionDone(LoadPartitionDoneEvent partSetDoneEvent)
                         throws MetaException

Overrides:

onLoadPartitionDone in class MetaStoreEventListener

Parameters:

partSetDoneEvent -

Throws:

MetaException