You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2021/10/29 21:26:15 UTC
[beam] branch master updated (cb9fb51 -> a5a0bd2)

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

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


    from cb9fb51  [BEAM-13099] Add build files for vendored Calcite 1.28.0
     add 3fe3e15  [BEAM-13015] Migrate bundle processing in the SDK harness to using BeamFnDataInboundObserver2 and BeamFnDataGrpcMultiplexer2.
     add a5a0bd2  [BEAM-13015] Migrate bundle processing in the SDK harness to using BeamFnDataInboundObserver2 and BeamFnDataGrpcMultiplexer2.

No new revisions were added by this update.

Summary of changes:
 .../sdk/fn/data/BeamFnDataGrpcMultiplexer.java     |   3 +
 .../sdk/fn/data/BeamFnDataGrpcMultiplexer2.java    |   5 -
 .../sdk/fn/data/BeamFnDataInboundObserver.java     |   3 +
 .../apache/beam/sdk/fn/data/InboundDataClient.java |   3 +
 .../fn}/data/BeamFnDataInboundObserverTest.java    |   7 +-
 .../beam/fn/harness/BeamFnDataReadRunner.java      |  31 +-
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    |  30 +-
 .../beam/fn/harness/PTransformRunnerFactory.java   |  10 +
 .../fn/harness/control/ProcessBundleHandler.java   | 109 ++++-
 .../beam/fn/harness/data/BeamFnDataClient.java     |  39 +-
 .../beam/fn/harness/data/BeamFnDataGrpcClient.java |  53 ++-
 .../beam/fn/harness/data/BeamFnTimerClient.java    |  28 +-
 .../fn/harness/data/BeamFnTimerGrpcClient.java     |  64 +--
 .../fn/harness/data/QueueingBeamFnDataClient.java  | 319 --------------
 .../fn/harness/state/FnApiTimerBundleTracker.java  |   6 +-
 .../beam/fn/harness/BeamFnDataReadRunnerTest.java  | 250 ++++-------
 .../beam/fn/harness/FnApiDoFnRunnerTest.java       |  60 ++-
 .../PTransformRunnerFactoryTestContext.java        |  60 ++-
 .../harness/control/ProcessBundleHandlerTest.java  | 173 +++++++-
 .../fn/harness/data/BeamFnDataGrpcClientTest.java  |  75 ++--
 .../fn/harness/data/FakeBeamFnTimerClient.java     |  96 +----
 .../harness/data/QueueingBeamFnDataClientTest.java | 470 ---------------------
 22 files changed, 593 insertions(+), 1301 deletions(-)
 rename sdks/java/{harness/src/test/java/org/apache/beam/fn/harness => fn-execution/src/test/java/org/apache/beam/sdk/fn}/data/BeamFnDataInboundObserverTest.java (92%)
 delete mode 100644 sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/QueueingBeamFnDataClient.java
 delete mode 100644 sdks/java/harness/src/test/java/org/apache/beam/fn/harness/data/QueueingBeamFnDataClientTest.java