This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 2db98ee Merge pull request #14526: [BEAM-12155] Fixes MetricsTest
assertion for non-portable path
add 4dd45e0 [BEAM-6597] Use short id metric protocol for Java. (#14482)
No new revisions were added by this update.
Summary of changes:
.../runners/core/metrics/MetricsContainerImpl.java | 129 +++++++++++++++------
.../core/metrics/MetricsContainerStepMap.java | 12 ++
.../beam/runners/core/metrics/ShortIdMap.java} | 48 ++++----
.../runners/core/metrics/SimpleExecutionState.java | 26 +++++
.../runners/core/metrics/SimpleStateRegistry.java | 10 ++
.../java/org/apache/beam/fn/harness/FnHarness.java | 24 +++-
.../fn/harness/control/ProcessBundleHandler.java | 85 ++++++++------
.../harness/data/PCollectionConsumerRegistry.java | 7 ++
.../harness/data/PTransformFunctionRegistry.java | 8 ++
.../harness/control/ProcessBundleHandlerTest.java | 13 +++
10 files changed, 265 insertions(+), 97 deletions(-)
copy
runners/core-java/src/{test/java/org/apache/beam/runners/core/metrics/MonitoringInfoConstantsTest.java
=> main/java/org/apache/beam/runners/core/metrics/ShortIdMap.java} (53%)