Hi devs, In FLIP-130, we have already supported Python DataStream stateless APIs so that users are able to perform some basic data transformations. To implement more complex data processing, we need to provide state access support. So I would propose to add state access APIs in Python DataStream API to support stateful operations on a KeyedStream. More details are in the FLIP wiki page [1].
Any feedback will be highly appreciated! [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-153%3A+Support+state+access+in+Python+DataStream+API Best, Shuiqiang
