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