Package com.zendesk.maxwell.scripting
Class WrappedRowMap
- java.lang.Object
-
- com.zendesk.maxwell.scripting.WrappedRowMap
-
public class WrappedRowMap extends Object
-
-
Constructor Summary
Constructors Constructor Description WrappedRowMap(RowMap row)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description LinkedHashMap<String,Object>
getData()
String
getDatabase()
LinkedHashMap<String,Object>
getExtra_attributes()
LinkedHashMap<String,Object>
getOld_data()
String
getPosition()
String
getQuery()
Long
getServer_id()
String
getTable()
Long
getThread_id()
Long
getTimestamp()
String
getType()
Long
getXid()
void
setKafka_topic(String topic)
void
setPartition_string(String partitionString)
void
setQuery(String query)
void
suppress()
-
-
-
Constructor Detail
-
WrappedRowMap
public WrappedRowMap(RowMap row)
-
-
Method Detail
-
getData
public LinkedHashMap<String,Object> getData()
-
getOld_data
public LinkedHashMap<String,Object> getOld_data()
-
getExtra_attributes
public LinkedHashMap<String,Object> getExtra_attributes()
-
getType
public String getType()
-
getTable
public String getTable()
-
getDatabase
public String getDatabase()
-
getPosition
public String getPosition()
-
getXid
public Long getXid()
-
getServer_id
public Long getServer_id()
-
getThread_id
public Long getThread_id()
-
getTimestamp
public Long getTimestamp()
-
getQuery
public String getQuery()
-
setQuery
public void setQuery(String query)
-
suppress
public void suppress()
-
setKafka_topic
public void setKafka_topic(String topic)
-
setPartition_string
public void setPartition_string(String partitionString)
-
-