Hi everyone, I'd like to start a vote soon if there is no further discussion.
Best, Zakelly On Wed, Dec 11, 2024 at 5:26 PM Zakelly Lan <zakelly....@gmail.com> wrote: > Hi Yanfei, > > Thanks for your response! > > The `SingleOutputStreamOperator` is the return type of `process()` or > `sum()`, so the example would be invoking `enableAsyncState()` after the > processing methods, which has been included in the examples within this > FLIP. > > > Best, > Zakelly > > On Wed, Dec 11, 2024 at 3:03 PM Yanfei Lei <fredia...@gmail.com> wrote: > >> Hi Zakelly, >> >> Thank for the proposal! This makes it easy for Datastream (V1) users >> to use async state processing. >> >> Currently, only keyed states can use async state processing, could you >> please add some examples about how `SingleOutputStreamOperator` use >> async state processing? >> >> Zakelly Lan <zakelly....@gmail.com> 于2024年12月5日周四 19:32写道： >> > >> > Hi Yunfeng, >> > >> > will this FLIP add `enableAsyncState` to `SingleOutputStreamOperator` as >> > > well? >> > >> > >> > Yes. Thanks for the reminder. >> > >> > >> > Best, >> > Zakelly >> > >> > On Thu, Dec 5, 2024 at 7:21 PM Yunfeng Zhou < >> flink.zhouyunf...@gmail.com> >> > wrote: >> > >> > > Hi Zakelly, >> > > >> > > Thank for the proposal! >> > > >> > > I noticed that it says users can invoke `enableAsyncState` after sum >> or >> > > process, thus will this FLIP add `enableAsyncState` to >> > > `SingleOutputStreamOperator` as well? >> > > >> > > Best, >> > > Yunfeng >> > > >> > > >> > > > 2024年12月4日 20:32，Zakelly Lan <zakelly....@gmail.com> 写道： >> > > > >> > > > Hi everyone, >> > > > >> > > > I'd like to start a discussion on FLIP-488: Expose Async State >> Processing >> > > > and New State APIs in Datastream(V1) APIs[1]. >> > > > >> > > > This FLIP allows Datastream users to leverage the capability of >> async >> > > state >> > > > query and disaggregated state management introduced in FLIP-423[2] >> and >> > > its >> > > > sub-FLIPs. >> > > > >> > > > Looking forward to hearing from you! >> > > > >> > > > [1] https://cwiki.apache.org/confluence/x/yIrREw >> > > > [2] https://cwiki.apache.org/confluence/x/R4p3EQ >> > > > >> > > > >> > > > Best, >> > > > Zakelly >> > > >> > > >> >> >> >> -- >> Best, >> Yanfei >> >
