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>.

Reply via email to