The model which is used for serializing with avro and storing the serialized data to RocksDB

txnModel.java

package com.airplus.poc.flink.model;

import com.airplus.poc.generated.xjc.RecordReadEventType;
import java.util.HashSet;

/**
 * @author Biplob Biswas on 22.08.2017.
 */
public class TransactionStateModel {
  private RecordReadEventType recordReadEvent;
  private HashSet<String> matchKeys;
  private Long timestamp;

  public TransactionStateModel() {
  }

  public TransactionStateModel(RecordReadEventType recordReadEvent, HashSet<String> matchKeys, Long timestamp) {
    this.recordReadEvent = recordReadEvent;
    this.matchKeys = matchKeys;
    this.timestamp = timestamp;
  }

  public RecordReadEventType getRecordReadEvent() {
    return recordReadEvent;
  }

  public void setRecordReadEvent(RecordReadEventType recordReadEvent) {
    this.recordReadEvent = recordReadEvent;
  }

  public HashSet<String> getMatchKeys() {
    return matchKeys;
  }

  public void setMatchKeys(HashSet<String> matchKeys) {
    this.matchKeys = matchKeys;
  }

  public Long getTimestamp() {
    return timestamp;
  }

  public void setTimestamp(Long timestamp) {
    this.timestamp = timestamp;
  }

  @Override
  public String toString() {
    return "TransactionStateModel{" +
            "recordReadEvent=" + recordReadEvent +
            ", matchKeys=" + matchKeys +
            ", timestamp=" + timestamp +
            '}';
  }
}