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", meaning it can get access to the RuntimeContext and use metrics, etc, but no keyed state. Stephan On Thu, Jan 19, 2017 at 3:51 AM, tao xiao <xiaotao...@gmail.com> wrote: > 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? >
