Hello, I would love to hear more about specific use cases you are interested in.
On the general topic of expressing computations in terms of mutable state cells, the user-facing State API is through design [1] and implementation is underway, tracked as BEAM-25 [2]. Kenn [1] http://s.apache.org/beam-state [2] https://issues.apache.org/jira/browse/BEAM-25 On Sun, Nov 20, 2016 at 7:27 PM, 陈竞 <[email protected]> wrote: > realtime computation based tate is very common and important in flink, > how beam deal with flink's State? >
