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

Posted to commits@beam.apache.org by yi...@apache.org on 2022/02/08 21:34:02 UTC

[beam] branch master updated (b14010d -> f2c36cf)

This is an automated email from the ASF dual-hosted git repository.

yichi pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.


    from b14010d  [BEAM-13321] Initial BigQueryIO externalization. (#16489)
     add f2c36cf  [BEAM-13193] Enable process bundle response elements embedding in Java SDK Harness (#16769)

No new revisions were added by this update.

Summary of changes:
 .../sdk/fn/data/BeamFnDataOutboundAggregator.java  | 40 +++++++--
 .../sdk/fn/data/BeamFnDataOutboundObserver.java    |  6 +-
 .../fn/data/BeamFnDataOutboundAggregatorTest.java  | 43 ++++++----
 .../beam/fn/harness/PTransformRunnerFactory.java   |  4 +
 .../fn/harness/control/ProcessBundleHandler.java   | 94 +++++++++++++++++----
 .../beam/fn/harness/data/BeamFnDataClient.java     | 11 ++-
 .../beam/fn/harness/data/BeamFnDataGrpcClient.java |  7 +-
 .../beam/fn/harness/BeamFnDataWriteRunnerTest.java |  3 +-
 .../beam/fn/harness/FnApiDoFnRunnerTest.java       |  2 +-
 .../PTransformRunnerFactoryTestContext.java        | 10 ++-
 .../harness/control/ProcessBundleHandlerTest.java  | 95 ++++++++++++++++++++--
 .../fn/harness/data/BeamFnDataGrpcClientTest.java  |  5 +-
 12 files changed, 258 insertions(+), 62 deletions(-)