flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kant kodali <kanth...@gmail.com>
Subject How does custom object/data structures get mapped into rocksdb underneath?
Date Mon, 09 Mar 2020 11:27:18 GMT
Hi All,

I want to do stateful streaming and I was wondering how Custom objects get
mapped into rocksdb?

say I have the following class that represents my state

public class MyState {
    private HashMap<String, T> map1 ; // T can be any type
    private HashMap<Integer, S> map2; // S can be any type

I wonder how these two maps gets mapped into rocksdb? and how does Flink
know that map1 and map2 together are part of my state but not
individual ones in isolation?


View raw message