将自定义数据添加到 Flink 指标
Add custom data to the Flink metrics
在 Apache Flink 中存在 4 种类型的指标。
目标是向直方图指标添加额外信息：user_id 和 speed_of_processing
例如：
user_id: speed_of_processing
1:30 sec
2:15 sec
...
如何添加此类信息？
您似乎想要测量端到端延迟并针对每个 user_id 单独报告。这与 flink 的指标不太匹配——拥有每个键（例如，每个用户）指标不是一个好主意——Flink 的指标系统在设计时并未考虑到这种规模。
您可以改为执行这些测量并将结果发送到接收器。或者使用仅报告所有用户汇总结果的直方图指标。
在 Apache Flink 中存在 4 种类型的指标。 目标是向直方图指标添加额外信息：user_id 和 speed_of_processing 例如：
user_id: speed_of_processing
1:30 sec
2:15 sec
... 如何添加此类信息？
您似乎想要测量端到端延迟并针对每个 user_id 单独报告。这与 flink 的指标不太匹配——拥有每个键（例如，每个用户）指标不是一个好主意——Flink 的指标系统在设计时并未考虑到这种规模。
您可以改为执行这些测量并将结果发送到接收器。或者使用仅报告所有用户汇总结果的直方图指标。