This is an automated email from the ASF dual-hosted git repository.
johncasey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from e7b4d6358c0 Upgrade to new vendored grpc (#33555)
add 2064103e607 Kafka add gauge v1 (#33408)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
.../dataflow/worker/DataflowMetricsContainer.java | 6 ++
.../MetricsToPerStepNamespaceMetricsConverter.java | 99 +++++++++++++++++-
.../worker/StreamingStepMetricsContainer.java | 29 +++++-
...ricsToPerStepNamespaceMetricsConverterTest.java | 113 +++++++++++++++++++--
...DelegatingCounter.java => DelegatingGauge.java} | 59 ++++-------
.../apache/beam/sdk/metrics/MetricsContainer.java | 8 ++
.../metrics/{NoOpHistogram.java => NoOpGauge.java} | 23 ++---
.../org/apache/beam/sdk/io/kafka/KafkaMetrics.java | 61 +++++++++--
.../apache/beam/sdk/io/kafka/KafkaSinkMetrics.java | 50 ++++++++-
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 20 +++-
.../apache/beam/sdk/io/kafka/KafkaMetricsTest.java | 21 +++-
12 files changed, 406 insertions(+), 85 deletions(-)
copy
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/{DelegatingCounter.java
=> DelegatingGauge.java} (52%)
copy
sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/{NoOpHistogram.java =>
NoOpGauge.java} (61%)
