public class JSONAddPartitionMessage extends AddPartitionMessage
EventMessage.EventType
eventType
Constructor and Description |
---|
JSONAddPartitionMessage()
Default Constructor.
|
JSONAddPartitionMessage(String server,
String servicePrincipal,
Table tableObj,
Iterator<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
|
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<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).
|
Table |
getTableObj() |
String |
getTableObjJson() |
String |
getTableType() |
Long |
getTimestamp()
Getter for the timestamp associated with the operation.
|
String |
toString() |
checkValid
getEventType
public JSONAddPartitionMessage()
public JSONAddPartitionMessage(String server, String servicePrincipal, Table tableObj, Iterator<Partition> partitionsIterator, Iterator<PartitionFiles> partitionFileIter, Long timestamp)
public String getServer()
EventMessage
getServer
in class EventMessage
public String getServicePrincipal()
EventMessage
getServicePrincipal
in class EventMessage
public String getDB()
EventMessage
getDB
in class EventMessage
public String getTable()
AddPartitionMessage
getTable
in class AddPartitionMessage
public String getTableType()
getTableType
in class AddPartitionMessage
public Table getTableObj() throws Exception
getTableObj
in class AddPartitionMessage
Exception
public Long getTimestamp()
EventMessage
getTimestamp
in class EventMessage
public List<Map<String,String>> getPartitions()
AddPartitionMessage
getPartitions
in class AddPartitionMessage
public Iterable<Partition> getPartitionObjs() throws Exception
getPartitionObjs
in class AddPartitionMessage
Exception
public String getTableObjJson()
public Iterable<PartitionFiles> getPartitionFilesIter()
AddPartitionMessage
getPartitionFilesIter
in class AddPartitionMessage
Copyright © 2022 The Apache Software Foundation. All rights reserved.