org.apache.hive.hcatalog.messaging.json

Class JSONInsertMessage

java.lang.Object

org.apache.hive.hcatalog.messaging.HCatEventMessage

org.apache.hive.hcatalog.messaging.InsertMessage

org.apache.hive.hcatalog.messaging.json.JSONInsertMessage

public class JSONInsertMessage
extends InsertMessage

JSON implementation of DropTableMessage.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hive.hcatalog.messaging.HCatEventMessage

HCatEventMessage.EventType

Field Summary

Fields inherited from class org.apache.hive.hcatalog.messaging.HCatEventMessage

eventType

Constructor Summary

Constructors

Constructor and Description
JSONInsertMessage() Default constructor, needed for Jackson.
JSONInsertMessage(String server, String servicePrincipal, String db, String table, Map<String,String> partKeyVals, List<String> files, Long timestamp)

Method Summary

Methods

Modifier and Type	Method and Description
String	getDB() Getter for the name of the Database on which the Metastore operation is done.
List<String>	getFiles() Get the list of files created as a result of this DML operation.
Map<String,String>	getPartitionKeyValues() Get the map of partition keyvalues.
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.
Long	getTimestamp() Getter for the timestamp associated with the operation.
String	toString()

Methods inherited from class org.apache.hive.hcatalog.messaging.InsertMessage

checkValid

Methods inherited from class org.apache.hive.hcatalog.messaging.HCatEventMessage

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,
                 String db,
                 String table,
                 Map<String,String> partKeyVals,
                 List<String> files,
                 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).

getServer

public String getServer()

Description copied from class: HCatEventMessage

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

Specified by:

getServer in class HCatEventMessage

Returns:

HCatalog Server's URL (String).

getPartitionKeyValues

public Map<String,String> getPartitionKeyValues()

Description copied from class: InsertMessage

Get the map of partition keyvalues. Will be null if this insert is to a table and not a partition.

Specified by:

getPartitionKeyValues in class InsertMessage

Returns:

Map of partition keyvalues, or null.

getFiles

public List<String> getFiles()

Description copied from class: InsertMessage

Get the list of files created as a result of this DML operation. May be null.

Specified by:

getFiles in class InsertMessage

Returns:

List of new files, or null.

getServicePrincipal

public String getServicePrincipal()

Description copied from class: HCatEventMessage

Getter for the Kerberos principal of the HCatalog service.

Specified by:

getServicePrincipal in class HCatEventMessage

Returns:

HCatalog Service Principal (String).

getDB

public String getDB()

Description copied from class: HCatEventMessage

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

Specified by:

getDB in class HCatEventMessage

Returns:

Database-name (String).

getTimestamp

public Long getTimestamp()

Description copied from class: HCatEventMessage

Getter for the timestamp associated with the operation.

Specified by:

getTimestamp in class HCatEventMessage

Returns:

Timestamp (Long - seconds since epoch).

toString

public String toString()

Overrides:

toString in class Object