Hi Francis,
You could inherit from the original `KeyedProcessFunction` to process async
state. Please do remember to use the ForSt Statebackends, which is the only
one that supports asynchronous state access. If your state size is huge,
you will get the benefit.
The `DeclaringAsyncKeyedProcessFun
Hello everyone,
I have a question about using the Async state APIs in a KeyedProcessFunction.
I’m defining a pipeline like this,
keyBy(KeySelector()).enableAsyncState().process(MyKeyedProcessFunction()).
Inside MyKeyedProcessFunction I’m using the
org.apache.flink.api.common.state.v2.ValueStat
