Re: [Discuss] Questions about SortedMapState in Stream API

2020-07-29 Thread Sean Z
Thanks for the reply. Yes, it's true that RocksDB only supports bytes-comparator which makes it challenging. I checked FLINK-6219 has already been closed with reason "The thing is this issue will be addressed after blink code gets merged, and we will open another Jira to track the requirements. "

Re: [Discuss] Questions about SortedMapState in Stream API

2020-07-25 Thread Congxian Qiu
Hi Sean AFAIK, Flink does not support SortedMapState currently, there was an issue FLINK-6219 about sorted mapstate before. I think you can reach to this issue if you want sorted mapstate. Sorted MapState for RocksDB can be challenging for Java-based comparator, RocksDB supports the bytes-com

[Discuss] Questions about SortedMapState in Stream API

2020-07-23 Thread Sean Z
Hi Flink Community, I'm new to this community but have been using Flink for a year or so. As a user, my team built stuff upon Flink stateful stream processing. We used to have a use case that we need a sorted map data structure to store our state, something like TreeMap in Java, to query higher/lo