没有明白你说的实现方式。 我最终要得到类似的 Metrics: myCounter_table1, myCounter_table2, ..., myCounter_tableX 但我看代码中 Metrics 的初始化都是在 open 方法中的，在这个方法中我没法得到 tableName 是什么。
谢谢， 王磊 ------------------------------------------------------------------ 发件人：JasonLee <[email protected]> 发送时间：2020年7月2日(星期四) 21:12 收件人：user-zh <[email protected]> 主 题：回复：在一个 flink operator 中怎样根据消息内容动态生成多个监控指标？ 你把tablename传到下面metric里不就行了吗 | | JasonLee | | 邮箱：[email protected] | Signature is customized by Netease Mail Master 在2020年07月02日 16:39，[email protected] 写道： 全都是同一种类型的 metrics. 比如消息中是 mysql binlog 解析结果，我想要根据消息内容拿到 tableName， 按 tableName 生成不同名称的 metrics（但都是 meter 类型） 谢谢， 王磊 [email protected] 发件人： JasonLee 发送时间： 2020-07-02 16:16 收件人： user-zh 主题： 回复：在一个 flink operator 中怎样根据消息内容动态生成多个监控指标？ 是要生成不同类型的metric吗 比如counter meter ？ | | JasonLee | | 邮箱：[email protected] | Signature is customized by Netease Mail Master 在2020年07月02日 15:34，[email protected] 写道： 官网上的例子： public class MyMapper extends RichMapFunction<String, String> { private transient Counter counter; @Override public void open(Configuration config) { this.counter = getRuntimeContext() .getMetricGroup() .counter("myCounter"); } @Override public String map(String value) throws Exception { this.counter.inc(); return value; } } 我想要根据 map 方法中传入的参数生成不同的 监控指标，怎样可以实现呢？ 谢谢， 王磊 [email protected]
