Hi All, I am wondering how Flink serializes and deserializes state from rockdb? What is the format used?
For example, say I am doing some stateful streaming and say an object for my class below represents a state. how does Flink serializes and deserializes the object of MyClass below? is it just Java or Kryo serialization? if so, are they queryable? public class MyClass { private Map<Integer, String> map1 = new HashMap<>(); private Map<Integer, String> map2 = new HashMap<>(); } Thanks!