public class JSONInsertMessage extends InsertMessage
EventMessage.EventType
eventType
Constructor and Description |
---|
JSONInsertMessage()
Default constructor, needed for Jackson.
|
JSONInsertMessage(String server,
String servicePrincipal,
Table tableObj,
Partition ptnObj,
boolean replace,
Iterator<String> fileIter,
Long timestamp) |
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
|
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.
|
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() |
checkValid
getEventType
public JSONInsertMessage()
public String getTable()
InsertMessage
getTable
in class InsertMessage
public String getTableType()
getTableType
in class InsertMessage
public String getServer()
EventMessage
getServer
in class EventMessage
public Iterable<String> getFiles()
InsertMessage
getFiles
in class InsertMessage
public String getServicePrincipal()
EventMessage
getServicePrincipal
in class EventMessage
public String getDB()
EventMessage
getDB
in class EventMessage
public Long getTimestamp()
EventMessage
getTimestamp
in class EventMessage
public boolean isReplace()
InsertMessage
isReplace
in class InsertMessage
public Table getTableObj() throws Exception
InsertMessage
getTableObj
in class InsertMessage
Exception
public Partition getPtnObj() throws Exception
InsertMessage
getPtnObj
in class InsertMessage
Exception
Copyright © 2022 The Apache Software Foundation. All rights reserved.