需要一种在我的Flink程序中编写自定义指标的方法

Question

我需要知道在我的Flink程序中实现自定义指标的方法。目前，我知道我们可以在RuntimeContext的帮助下创建自定义指标。但是在我的Excregate（）中，我没有runtimecontext。我正在使用窗口操作员，并在其上应用centregate（）方法。我正在通过engregate（）方法传递聚合功能。

那么，请指导我，如何在代码中创建自定义指标？

注意：众所周知，我们无法用gencregate（）method

Answer 1

如果您的目标是使用每个元素更新度量，我认为您必须实现一个自定义窗口操作员，其中覆盖开放和过程元素方法。

通常不建议参与操作员内部内容，但有时这是访问所需的接口的唯一方法。