This is an automated email from the ASF dual-hosted git repository.
tgroh pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 9acffa69a3305afde76266220b73d31d8fe1eb8f
Merge: 664feec d799fe0
Author: Thomas Groh <tg...@users.noreply.github.com>
AuthorDate: Wed Dec 13 17:24:43 2017 -0800
Merge pull request #4203
Use FnDataReceiver in the SDK Harness
.../fnexecution/control/SdkHarnessClient.java | 43 ++++----
.../runners/fnexecution/data/FnDataService.java | 3 +-
.../data/BeamFnDataBufferingOutboundObserver.java | 2 +-
...aReceiver.java => CloseableFnDataReceiver.java} | 12 +--
.../apache/beam/sdk/fn/data/FnDataReceiver.java | 9 +-
.../BeamFnDataBufferingOutboundObserverTest.java | 4 +-
.../beam/fn/harness/BeamFnDataReadRunner.java | 31 +++---
.../beam/fn/harness/BeamFnDataWriteRunner.java | 20 ++--
.../beam/fn/harness/BoundedSourceRunner.java | 25 +++--
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 44 ++++----
.../beam/fn/harness/PTransformRunnerFactory.java | 28 ++---
.../fn/harness/control/ProcessBundleHandler.java | 17 +--
.../data/BeamFnDataBufferingOutboundObserver.java | 4 +-
.../beam/fn/harness/data/BeamFnDataClient.java | 28 ++---
.../beam/fn/harness/data/BeamFnDataGrpcClient.java | 10 +-
.../fn/harness/data/BeamFnDataInboundObserver.java | 6 +-
.../harness/data/MultiplexingFnDataReceiver.java | 50 +++++++++
.../beam/fn/harness/BeamFnDataReadRunnerTest.java | 18 ++--
.../beam/fn/harness/BeamFnDataWriteRunnerTest.java | 28 ++---
.../beam/fn/harness/BoundedSourceRunnerTest.java | 12 +--
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 14 +--
.../harness/control/ProcessBundleHandlerTest.java | 52 +++++-----
.../BeamFnDataBufferingOutboundObserverTest.java | 6 +-
.../fn/harness/data/BeamFnDataGrpcClientTest.java | 42 ++++----
.../data/BeamFnDataInboundObserverTest.java | 12 +--
.../data/MultiplexingFnDataReceiverTest.java | 115 +++++++++++++++++++++
26 files changed, 401 insertions(+), 234 deletions(-)
--
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <commits@beam.apache.org>.
