Hi!
There is a window variant where you can use both a ReduceFunction and a
Window Function. You can use the metrics in the WindowFunction. Does that
help your use case, or do you need the metrics strictly in the
ReduceFunction?
There are thoughts to allow the ReduceFunction to be "semi-rich", me
Hi team,
Is there any way that I can register a metric in a window reduce function?
As per the flink doc getRuntimecontext is only available in RichFunction
but window operator doesn't allow RichFunction to be chained. Any way to
workaround this?
