是否可以在 FileIO 等接收器中跟踪指标？
Is it possible to track Metrics within a sink such as FileIO?
玩 org.apache.beam.sdk.metrics 想知道以下问题... 你能跟踪来自 一个“晦涩难懂”的指标吗（我所说的晦涩难懂是指 那个阶段的代码不是你的) 以捕获失败、延迟等，例如，当插入失败时在 CassandraIO 连接器内？
如果是这样，我如何访问该信息？
到目前为止，我一直在我自己的阶段跟踪指标，做 Metrics.counter("new_counter", "new_metric").inc(n) 和类似的事情。
指标需要手动添加到每个连接器，就像您已经对自己的指标所做的那样（即 Metrics.counter(.....).inc(..)）。
如果连接器有自己的指标，它会发布它们。不幸的是，CassandraIO 似乎并非如此。 : (
如果您有兴趣，我会邀请您向 Apache Beam 存储库提交拉取请求，以添加您认为对 CassandraIO 或您喜欢的任何其他连接器感兴趣的指标。
玩 org.apache.beam.sdk.metrics 想知道以下问题... 你能跟踪来自 一个“晦涩难懂”的指标吗（我所说的晦涩难懂是指 那个阶段的代码不是你的) 以捕获失败、延迟等，例如，当插入失败时在 CassandraIO 连接器内？
如果是这样，我如何访问该信息？
到目前为止，我一直在我自己的阶段跟踪指标，做 Metrics.counter("new_counter", "new_metric").inc(n) 和类似的事情。
指标需要手动添加到每个连接器，就像您已经对自己的指标所做的那样（即 Metrics.counter(.....).inc(..)）。
如果连接器有自己的指标，它会发布它们。不幸的是，CassandraIO 似乎并非如此。 : (
如果您有兴趣，我会邀请您向 Apache Beam 存储库提交拉取请求，以添加您认为对 CassandraIO 或您喜欢的任何其他连接器感兴趣的指标。