org.apache.hadoop.hive.metastore.messaging

Class InsertMessage

java.lang.Object

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

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

Direct Known Subclasses:

JSONInsertMessage

public abstract class InsertMessage
extends EventMessage

HCat message sent when an insert is done to a table or partition.

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

Modifier	Constructor and Description
protected	InsertMessage()

Method Summary

Modifier and Type	Method and Description
EventMessage	checkValid() Class invariant.
abstract Iterable<String>	getFiles() Get list of file name and checksum created as a result of this DML operation
abstract org.apache.hadoop.hive.metastore.api.Partition	getPtnObj() Get the partition object associated with the insert
abstract String	getTable() Getter for the name of the table being insert into.
abstract org.apache.hadoop.hive.metastore.api.Table	getTableObj() Get the table object associated with the insert
abstract String	getTableType()
abstract boolean	isReplace() Getter for the replace flag being insert into/overwrite

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

getDB, getEventType, getServer, getServicePrincipal, getTimestamp

Methods inherited from class java.lang.Object

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

Constructor Detail

InsertMessage

protected InsertMessage()

Method Detail

getTable

public abstract String getTable()

Getter for the name of the table being insert into.

Returns:

Table-name (String).

getTableType

public abstract String getTableType()

isReplace

public abstract boolean isReplace()

Getter for the replace flag being insert into/overwrite

Returns:

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

getFiles

public abstract Iterable<String> getFiles()

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

Returns:

The iterable of files

getTableObj

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

Get the table object associated with the insert

Returns:

The Json format of Table object

Throws:

Exception

getPtnObj

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

Get the partition object associated with the insert

Returns:

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

Throws:

Exception

checkValid

public EventMessage checkValid()

Description copied from class: EventMessage

Class invariant. Checked after construction or deserialization.

Overrides:

checkValid in class EventMessage