I looked at that code, but I’m still not clear. new RocksDBMapState<>(columnFamily, namespaceSerializer, stateDesc, this);
columnFamily is determined by 50-line function; is this necessary for a simple use case like mine? What should I use as state descriptor in that function?.. Last argument is set to “this”; does this mean I need to implement AbstractKeyedStateBackend, like RocksDBKeyedStateBackend does? Again, I’m looking for a simple equivalent to new HashMap(); or to JedisPool pool = new JedisPool(new JedisPoolConfig(), redisHost); Jedis jedis = pool.getResource(); Thanks, Alex From: Ted Yu [mailto:yuzhih...@gmail.com] Sent: Monday, April 09, 2018 11:48 AM To: user <user@flink.apache.org> Subject: Re: RocksDBMapState example? Hi, Have you looked at the ctor call in : flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBKeyedStateBackend.java around line 1261 ? Cheers
