beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rober...@apache.org
Subject [beam] branch master updated (a9a1c8e -> bbaaeb0)
Date Tue, 08 Dec 2020 23:02:57 GMT
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 a9a1c8e  Merge pull request #13507 from [BEAM-11417] Use Cache with time eviction
policy for commitCallbacks
     add bbaaeb0  Decode data channel elements after, rather than before, placing them in
the queue. (#13387)

No new revisions were added by this update.

Summary of changes:
 .../worker/fn/data/BeamFnDataGrpcService.java      | 14 ++++-----
 .../runners/fnexecution/data/GrpcDataService.java  |  6 ++--
 .../sdk/fn/data/BeamFnDataInboundObserver.java     | 35 ++++++----------------
 .../beam/sdk/fn/data/DecodingFnDataReceiver.java   | 35 ++++++++++++----------
 .../beam/fn/harness/data/BeamFnDataClient.java     | 14 +++++++--
 .../beam/fn/harness/data/BeamFnDataGrpcClient.java | 10 +++----
 .../fn/harness/data/QueueingBeamFnDataClient.java  | 11 +++----
 .../data/BeamFnDataInboundObserverTest.java        | 11 ++++---
 8 files changed, 69 insertions(+), 67 deletions(-)
 copy runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/WindmillComputationKey.java
=> sdks/java/fn-execution/src/main/java/org/apache/beam/sdk/fn/data/DecodingFnDataReceiver.java
(51%)


Mime
View raw message