Hi devs,
Current DataStream API doesn't have SortedMapState supported. There are
lots of use cases based on sorted time-series data like range-query or
higher/lower key fetch, and ordered data seems like a nature of time-series
stream processing. Therefore, we propose to support the KeyedSortedMap
mporalState in our prototype.
>
> I look forward to sharing what we learned, and to discussing this further,
> but I am completely overwhelmed with Flink Forward preparations at the
> moment.
>
> Best,
> David
>
> On Wed, Oct 14, 2020 at 9:30 AM Sean Z wrote:
>
> &g
https://github.com/apache/flink/tree/blink/flink-libraries/flink-table/src/main/java/org/apache/flink/table/typeutils/ordered
>
> Best,
> Jark
>
> On Thu, 15 Oct 2020 at 06:46, Sean Z wrote:
>
> > Thanks for the reply! Look forward to learning more about this prototype.
&
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
ntly, 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-comparator only.
>
> Best,
> Congxian
Sean Z created FLINK-19708:
--
Summary: Support KeyedSortedMapState in DataStream API
Key: FLINK-19708
URL: https://issues.apache.org/jira/browse/FLINK-19708
Project: Flink
Issue Type: New Feature
Sean Z created FLINK-19709:
--
Summary: Support KeyedSortedMapState in DataStream API
Key: FLINK-19709
URL: https://issues.apache.org/jira/browse/FLINK-19709
Project: Flink
Issue Type: New Feature
