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