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

Posted to commits@beam.apache.org by tg...@apache.org on 2017/12/06 21:09:46 UTC

[beam] 01/01: Merge pull request #4202

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 defd0294f091c93c749db97d9dae31e3d9e4e134
Merge: df326cb 3d1c966
Author: Thomas Groh <tg...@users.noreply.github.com>
AuthorDate: Wed Dec 6 13:09:41 2017 -0800

    Merge pull request #4202
    
    Extract LogicalEndpoint to java-fn-execution

 .../runners/fnexecution/data/FnDataService.java    | 20 +----------
 sdks/java/fn-execution/build.gradle                |  1 +
 sdks/java/fn-execution/pom.xml                     | 12 +++++++
 .../apache/beam/sdk/fn/data/LogicalEndpoint.java   | 39 ++++++++++++++++++++
 .../org/apache/beam/sdk/fn/data/package-info.java  | 22 ++++++++++++
 .../beam/fn/harness/BeamFnDataReadRunner.java      |  4 +--
 .../beam/fn/harness/BeamFnDataWriteRunner.java     |  4 +--
 .../data/BeamFnDataBufferingOutboundObserver.java  | 18 +++++-----
 .../beam/fn/harness/data/BeamFnDataClient.java     |  7 ++--
 .../beam/fn/harness/data/BeamFnDataGrpcClient.java | 14 ++++----
 .../fn/harness/data/BeamFnDataGrpcMultiplexer.java | 14 ++++----
 .../beam/fn/harness/BeamFnDataReadRunnerTest.java  |  8 ++---
 .../beam/fn/harness/BeamFnDataWriteRunnerTest.java |  8 ++---
 .../BeamFnDataBufferingOutboundObserverTest.java   | 17 ++++-----
 .../fn/harness/data/BeamFnDataGrpcClientTest.java  | 42 +++++++++++-----------
 .../data/BeamFnDataGrpcMultiplexerTest.java        | 14 ++++----
 16 files changed, 149 insertions(+), 95 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <co...@beam.apache.org>.