org.apache.hadoop.hive.metastore.messaging.json

Class JSONInsertMessage

java.lang.Object

org.apache.hadoop.hive.metastore.messaging.EventMessage

org.apache.hadoop.hive.metastore.messaging.InsertMessage

org.apache.hadoop.hive.metastore.messaging.json.JSONInsertMessage

public class JSONInsertMessage
extends InsertMessage

JSON implementation of InsertMessage

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.metastore.messaging.EventMessage

EventMessage.EventType

Field Summary

Fields inherited from class org.apache.hadoop.hive.metastore.messaging.EventMessage

eventType

Constructor Summary

Constructors

Constructor and Description
JSONInsertMessage() Default constructor, needed for Jackson.
JSONInsertMessage(String server, String servicePrincipal, org.apache.hadoop.hive.metastore.api.Table tableObj, org.apache.hadoop.hive.metastore.api.Partition ptnObj, boolean replace, Iterator<String> fileIter, Long timestamp)

Method Summary

Modifier and Type	Method and Description
String	getDB() Getter for the name of the Database on which the Metastore operation is done.
Iterable<String>	getFiles() Get list of file name and checksum created as a result of this DML operation
org.apache.hadoop.hive.metastore.api.Partition	getPtnObj() Get the partition object associated with the insert
String	getServer() Getter for HCatalog Server's URL.
String	getServicePrincipal() Getter for the Kerberos principal of the HCatalog service.
String	getTable() Getter for the name of the table being insert into.
org.apache.hadoop.hive.metastore.api.Table	getTableObj() Get the table object associated with the insert
String	getTableType()
Long	getTimestamp() Getter for the timestamp associated with the operation.
boolean	isReplace() Getter for the replace flag being insert into/overwrite
String	toString()

Methods inherited from class org.apache.hadoop.hive.metastore.messaging.InsertMessage

checkValid

Methods inherited from class org.apache.hadoop.hive.metastore.messaging.EventMessage

getEventType

Methods inherited from class java.lang.Object

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

Constructor Detail

JSONInsertMessage

public JSONInsertMessage()

Default constructor, needed for Jackson.

JSONInsertMessage

public JSONInsertMessage(String server,
                         String servicePrincipal,
                         org.apache.hadoop.hive.metastore.api.Table tableObj,
                         org.apache.hadoop.hive.metastore.api.Partition ptnObj,
                         boolean replace,
                         Iterator<String> fileIter,
                         Long timestamp)

Method Detail

getTable

public String getTable()

Description copied from class: InsertMessage

Getter for the name of the table being insert into.

Specified by:

getTable in class InsertMessage

Returns:

Table-name (String).

getTableType

public String getTableType()

Specified by:

getTableType in class InsertMessage

getServer

public String getServer()

Description copied from class: EventMessage

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

Specified by:

getServer in class EventMessage

Returns:

HCatalog Server's URL (String).

getFiles

public Iterable<String> getFiles()

Description copied from class: InsertMessage

Get list of file name and checksum created as a result of this DML operation

Specified by:

getFiles in class InsertMessage

Returns:

The iterable of files

getServicePrincipal

public String getServicePrincipal()

Description copied from class: EventMessage

Getter for the Kerberos principal of the HCatalog service.

Specified by:

getServicePrincipal in class EventMessage

Returns:

HCatalog Service Principal (String).

getDB

public String getDB()

Description copied from class: EventMessage

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

Specified by:

getDB in class EventMessage

Returns:

Database-name (String).

getTimestamp

public Long getTimestamp()

Description copied from class: EventMessage

Getter for the timestamp associated with the operation.

Specified by:

getTimestamp in class EventMessage

Returns:

Timestamp (Long - seconds since epoch).

isReplace

public boolean isReplace()

Description copied from class: InsertMessage

Getter for the replace flag being insert into/overwrite

Specified by:

isReplace in class InsertMessage

Returns:

Replace flag to represent INSERT INTO or INSERT OVERWRITE (Boolean).

getTableObj

public org.apache.hadoop.hive.metastore.api.Table getTableObj()
                                                       throws Exception

Description copied from class: InsertMessage

Get the table object associated with the insert

Specified by:

getTableObj in class InsertMessage

Returns:

The Json format of Table object

Throws:

Exception

getPtnObj

public org.apache.hadoop.hive.metastore.api.Partition getPtnObj()
                                                         throws Exception

Description copied from class: InsertMessage

Get the partition object associated with the insert

Specified by:

getPtnObj in class InsertMessage

Returns:

The Json format of Partition object if the table is partitioned else return null.

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object