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()StringgetDatabase()LinkedHashMap<String,Object>getExtra_attributes()LinkedHashMap<String,Object>getOld_data()StringgetPosition()StringgetQuery()LonggetServer_id()StringgetTable()LonggetThread_id()LonggetTimestamp()StringgetType()LonggetXid()voidsetKafka_topic(String topic)voidsetPartition_string(String partitionString)voidsetQuery(String query)voidsuppress()
-
-
-
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)
-
-