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/07 19:15:08 UTC
[beam] branch master updated (98e5fc5 -> 74d94ea)

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 98e5fc5  [BEAM-11971] Revert "Fix timer consistency in direct runner" (#16748)
     add 74d94ea  [BEAM-13193] Aggregates fn api outbound data/timers of different endpoints (#16439)

No new revisions were added by this update.

Summary of changes:
 .../worker/fn/data/BeamFnDataGrpcService.java      |  10 +-
 .../runners/fnexecution/data/FnDataService.java    |   5 +
 .../runners/fnexecution/data/GrpcDataService.java  |   8 +-
 .../data/BeamFnDataBufferingOutboundObserver.java  | 102 ------
 .../sdk/fn/data/BeamFnDataOutboundAggregator.java  | 389 +++++++++++++++++++++
 .../sdk/fn/data/BeamFnDataOutboundObserver.java    |  85 +++++
 ...amFnDataSizeBasedBufferingOutboundObserver.java | 144 --------
 ...amFnDataTimeBasedBufferingOutboundObserver.java | 119 -------
 .../fn/data/BeamFnDataOutboundAggregatorTest.java  | 386 ++++++++++++++++++++
 ...DataSizeBasedBufferingOutboundObserverTest.java | 210 -----------
 ...DataTimeBasedBufferingOutboundObserverTest.java | 178 ----------
 .../beam/fn/harness/BeamFnDataWriteRunner.java     | 123 ++-----
 .../apache/beam/fn/harness/FnApiDoFnRunner.java    |  42 +--
 .../beam/fn/harness/PTransformRunnerFactory.java   |  19 +-
 .../fn/harness/control/ProcessBundleHandler.java   | 113 +++---
 .../beam/fn/harness/data/BeamFnDataClient.java     |  20 +-
 .../beam/fn/harness/data/BeamFnDataGrpcClient.java |  38 +-
 .../beam/fn/harness/data/BeamFnTimerClient.java    |  40 ---
 .../fn/harness/data/BeamFnTimerGrpcClient.java     |  48 ---
 .../fn/harness/state/FnApiTimerBundleTracker.java  |   5 +-
 .../beam/fn/harness/BeamFnDataWriteRunnerTest.java | 187 ++++------
 .../beam/fn/harness/FnApiDoFnRunnerTest.java       |  78 ++++-
 .../PTransformRunnerFactoryTestContext.java        |  76 +++-
 .../harness/control/ProcessBundleHandlerTest.java  | 131 +++----
 .../fn/harness/data/BeamFnDataGrpcClientTest.java  |  19 +-
 .../fn/harness/data/FakeBeamFnTimerClient.java     |  68 ----
 26 files changed, 1278 insertions(+), 1365 deletions(-)
 delete mode 100644 sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataBufferingOutboundObserver.java
 create mode 100644 sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataOutboundAggregator.java
 create mode 100644 sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataOutboundObserver.java
 delete mode 100644 sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataSizeBasedBufferingOutboundObserver.java
 delete mode 100644 sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/BeamFnDataTimeBasedBufferingOutboundObserver.java
 create mode 100644 sdks/java/fn-execution/src/test/java/org/apache/beam/sdk/fn/data/BeamFnDataOutboundAggregatorTest.java
 delete mode 100644 sdks/java/fn-execution/src/test/java/org/apache/beam/sdk/fn/data/BeamFnDataSizeBasedBufferingOutboundObserverTest.java
 delete mode 100644 sdks/java/fn-execution/src/test/java/org/apache/beam/sdk/fn/data/BeamFnDataTimeBasedBufferingOutboundObserverTest.java
 delete mode 100644 sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnTimerClient.java
 delete mode 100644 sdks/java/harness/src/main/java/org/apache/beam/fn/harness/data/BeamFnTimerGrpcClient.java
 delete mode 100644 sdks/java/harness/src/test/java/org/apache/beam/fn/harness/data/FakeBeamFnTimerClient.java