org.apache.hive.hcatalog.messaging

Class HCatEventMessage

java.lang.Object

org.apache.hive.hcatalog.messaging.HCatEventMessage

Direct Known Subclasses:

AddPartitionMessage, AlterPartitionMessage, AlterTableMessage, CreateDatabaseMessage, CreateTableMessage, DropDatabaseMessage, DropPartitionMessage, DropTableMessage, InsertMessage

public abstract class HCatEventMessage
extends Object

Class representing messages emitted when Metastore operations are done. (E.g. Creation and deletion of databases, tables and partitions.)

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HCatEventMessage.EventType Enumeration of all supported types of Metastore operations.

Field Summary

Fields

Modifier and Type	Field and Description
protected HCatEventMessage.EventType	eventType

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HCatEventMessage(HCatEventMessage.EventType eventType)

Method Summary

Methods

Modifier and Type	Method and Description
HCatEventMessage	checkValid() Class invariant.
abstract String	getDB() Getter for the name of the Database on which the Metastore operation is done.
HCatEventMessage.EventType	getEventType()
abstract String	getServer() Getter for HCatalog Server's URL.
abstract String	getServicePrincipal() Getter for the Kerberos principal of the HCatalog service.
abstract Long	getTimestamp() Getter for the timestamp associated with the operation.

Methods inherited from class java.lang.Object

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

Field Detail

eventType

protected HCatEventMessage.EventType eventType

Constructor Detail

HCatEventMessage

protected HCatEventMessage(HCatEventMessage.EventType eventType)

Method Detail

getEventType

public HCatEventMessage.EventType getEventType()

getServer

public abstract String getServer()

Getter for HCatalog Server's URL. (This is where the event originates from.)

Returns:

HCatalog Server's URL (String).

getServicePrincipal

public abstract String getServicePrincipal()

Getter for the Kerberos principal of the HCatalog service.

Returns:

HCatalog Service Principal (String).

getDB

public abstract String getDB()

Getter for the name of the Database on which the Metastore operation is done.

Returns:

Database-name (String).

getTimestamp

public abstract Long getTimestamp()

Getter for the timestamp associated with the operation.

Returns:

Timestamp (Long - seconds since epoch).

checkValid

public HCatEventMessage checkValid()

Class invariant. Checked after construction or deserialization.