This is an automated email from the ASF dual-hosted git repository.
yhu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 0b06cd897d2 Fix BigQuerySinkMetrics constants and increment metrics in
more places. (#30067)
add 0c2b1a512db Add converter class to convert metrics to
PerStepNamespaceMetrics (#30084)
No new revisions were added by this update.
Summary of changes:
.../MetricsToPerStepNamespaceMetricsConverter.java | 199 ++++++++++++++
...ricsToPerStepNamespaceMetricsConverterTest.java | 293 +++++++++++++++++++++
2 files changed, 492 insertions(+)
create mode 100644
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/MetricsToPerStepNamespaceMetricsConverter.java
create mode 100644
runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/MetricsToPerStepNamespaceMetricsConverterTest.java
