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

Reply via email to