You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ro...@apache.org on 2021/04/23 22:03:56 UTC

[beam] branch master updated (baa106e -> c3025ec)

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 baa106e  Merge pull request #14570 from [BEAM-12193] Add user metrics to show founded TopicPartition
     add c3025ec  [BEAM-12204] Allow unboundedly large side inputs in portable Java. (#14604)

No new revisions were added by this update.

Summary of changes:
 .../apache/beam/fn/harness/state/BagUserState.java |   7 +-
 .../beam/fn/harness/state/IterableSideInput.java   |   9 +-
 .../beam/fn/harness/state/MultimapSideInput.java   |  17 +--
 .../fn/harness/state/StateFetchingIterators.java   | 118 ++++++++++++++++++-
 .../beam/fn/harness/FnApiDoFnRunnerTest.java       |   4 +-
 .../fn/harness/state/FakeBeamFnStateClient.java    |  55 +++++++--
 .../harness/state/StateFetchingIteratorsTest.java  | 131 +++++++++++++++++----
 7 files changed, 278 insertions(+), 63 deletions(-)