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 >
