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

Class JSONAddPartitionMessage

java.lang.Object

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

org.apache.hadoop.hive.metastore.messaging.AddPartitionMessage

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

public class JSONAddPartitionMessage
extends AddPartitionMessage

JSON implementation of AddPartitionMessage.

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
JSONAddPartitionMessage() Default Constructor.
JSONAddPartitionMessage(String server, String servicePrincipal, org.apache.hadoop.hive.metastore.api.Table tableObj, Iterator<org.apache.hadoop.hive.metastore.api.Partition> partitionsIterator, Iterator<PartitionFiles> partitionFileIter, Long timestamp) Note that we get an Iterator rather than an Iterable here: so we can only walk thru the list once

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<PartitionFiles>	getPartitionFilesIter() Get iterable of partition name and file lists created as a result of this DDL operation
List<String>	getPartitionListJson()
Iterable<org.apache.hadoop.hive.metastore.api.Partition>	getPartitionObjs()
List<Map<String,String>>	getPartitions() Getter for list of partitions added.
String	getServer() Getter for HCatalog Server's URL.
String	getServicePrincipal() Getter for the Kerberos principal of the HCatalog service.
String	getTable() Getter for name of table (where partitions are added).
org.apache.hadoop.hive.metastore.api.Table	getTableObj()
String	getTableObjJson()
String	getTableType()
Long	getTimestamp() Getter for the timestamp associated with the operation.
String	toString()

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

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

JSONAddPartitionMessage

public JSONAddPartitionMessage()

Default Constructor. Required for Jackson.

JSONAddPartitionMessage

public JSONAddPartitionMessage(String server,
                               String servicePrincipal,
                               org.apache.hadoop.hive.metastore.api.Table tableObj,
                               Iterator<org.apache.hadoop.hive.metastore.api.Partition> partitionsIterator,
                               Iterator<PartitionFiles> partitionFileIter,
                               Long timestamp)

Note that we get an Iterator rather than an Iterable here: so we can only walk thru the list once

Method Detail

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).

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).

getTable

public String getTable()

Description copied from class: AddPartitionMessage

Getter for name of table (where partitions are added).

Specified by:

getTable in class AddPartitionMessage

Returns:

Table-name (String).

getTableType

public String getTableType()

Specified by:

getTableType in class AddPartitionMessage

getTableObj

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

Specified by:

getTableObj in class AddPartitionMessage

Throws:

Exception

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).

getPartitions

public List<Map<String,String>> getPartitions()

Description copied from class: AddPartitionMessage

Getter for list of partitions added.

Specified by:

getPartitions in class AddPartitionMessage

Returns:

List of maps, where each map identifies values for each partition-key, for every added partition.

getPartitionObjs

public Iterable<org.apache.hadoop.hive.metastore.api.Partition> getPartitionObjs()
                                                                          throws Exception

Specified by:

getPartitionObjs in class AddPartitionMessage

Throws:

Exception

getTableObjJson

public String getTableObjJson()

getPartitionListJson

public List<String> getPartitionListJson()

toString

public String toString()

Overrides:

toString in class Object

getPartitionFilesIter

public Iterable<PartitionFiles> getPartitionFilesIter()

Description copied from class: AddPartitionMessage

Get iterable of partition name and file lists created as a result of this DDL operation

Specified by:

getPartitionFilesIter in class AddPartitionMessage

Returns:

The iterable of partition PartitionFiles