Class WrappedRowMap


  • public class WrappedRowMap
    extends Object
    • Constructor Detail

      • WrappedRowMap

        public WrappedRowMap​(RowMap row)
    • Method Detail

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