Hello Community,
Can you please give me some pointers for implementing Machine Learning
using Flink.
I see Flink ML libraries were dropped in v1.9. It looks like ML feature in
Flink going to be enhanced.
What is the recommended approach for implementing production grade ML based
apps using Flink
it with timers [2] in that same stateful function.
>>
>> Best,
>> Andrey
>>
>> [1]
>> https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/stream/state/state.html#using-managed-keyed-state
>> [2]
>> https://ci.apache.org/projects/flink/flin
*Emit intermediate accumulator(AggregateFunction ACC value) state of a
session window when new event arrives*
AggregateFunction#getResults() is called only when window completes. My
need is emit intermediate accumulator values(result of
AggregateFunction#add()) as well and write them to Sink. Bo
