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" <commits@beam.apache.org>.