是否可以在像FileIO这样的接收器中跟踪度量



org.apache.beam.sdk.metrics时想知道以下内容您可以跟踪和";模糊的";(我所说的模糊是指该阶段的代码不是您的(来捕获故障、延迟等,例如,当插入失败时,在CassandraIO连接器中?

如果是,我如何访问这些信息?

到目前为止,我一直在自己的阶段跟踪Metrics.counter("new_counter", "new_metric").inc(n)和类似的指标。

度量需要手动添加到每个连接器,就像您已经使用自己的度量(即Metrics.counter(.....).inc(..)(一样。

如果连接器有自己的度量,它将发布这些度量。不幸的是,CassandraIO似乎并非如此(

如果你感兴趣,我会邀请你向Apache Beam存储库提交一个拉取请求,以添加你觉得对CassandraIO或任何其他你喜欢的连接器感兴趣的指标。

最新更新