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

Posted to commits@beam.apache.org by ro...@apache.org on 2020/12/08 23:02:57 UTC

[beam] branch master updated (a9a1c8e -> bbaaeb0)

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%)