This is an automated email from the ASF dual-hosted git repository.
ccy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 1b7a7a1da22d1356d59b506ab9ddd3e4f085d259
Merge: da8cbc9 45e835a
Author: Charles Chen <charlesccyc...@users.noreply.github.com>
AuthorDate: Sun Nov 11 22:43:11 2018 -0800
Merge pull request #6940 from robertwb/bounded-buffer
[BEAM-5791] Implement time-based pushback in the dataflow harness data
plane.
.../worker/fn/control/BeamFnMapTaskExecutor.java | 47 +++++---
.../control/RegisterAndProcessBundleOperation.java | 9 ++
.../fn/data/RemoteGrpcPortWriteOperation.java | 121 ++++++++++++++++++++-
.../dataflow/worker/FnApiWindowMappingFnTest.java | 3 +
.../fn/control/BeamFnMapTaskExecutorTest.java | 2 +
.../SingularProcessBundleProgressTrackerTest.java | 2 +
.../fn/data/RemoteGrpcPortWriteOperationTest.java | 83 +++++++++++++-
.../data/BeamFnDataBufferingOutboundObserver.java | 9 +-
.../beam/sdk/fn/data/CloseableFnDataReceiver.java | 11 ++
.../beam/fn/harness/BeamFnDataWriteRunnerTest.java | 10 ++
10 files changed, 280 insertions(+), 17 deletions(-)
