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%)

Reply via email to