This closes #3986
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4f4632cc Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4f4632cc Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4f4632cc Branch: refs/heads/mr-runner Commit: 4f4632cccef6e1f0890bfc333534c186a2065aeb Parents: fbcb0ba 927a8db Author: Thomas Groh <tg...@google.com> Authored: Thu Nov 2 18:25:12 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Thu Nov 2 18:25:12 2017 -0700 ---------------------------------------------------------------------- ...job_beam_PostCommit_Java_MavenInstall.groovy | 2 +- .../job_beam_PreCommit_Java_MavenInstall.groovy | 4 +- pom.xml | 67 +++++++- runners/java-fn-execution/pom.xml | 105 ++++++++++++ .../beam/runners/fnexecution/ServerFactory.java | 104 ++++++++++++ .../beam/runners/fnexecution/package-info.java | 23 +++ .../runners/fnexecution/ServerFactoryTest.java | 128 +++++++++++++++ runners/pom.xml | 1 + sdks/java/fn-execution/pom.xml | 96 +++++++++++ .../harness/channel/ManagedChannelFactory.java | 82 ++++++++++ .../harness/channel/SocketAddressFactory.java | 64 ++++++++ .../beam/harness/channel/package-info.java | 22 +++ .../channel/ManagedChannelFactoryTest.java | 71 ++++++++ .../channel/SocketAddressFactoryTest.java | 56 +++++++ .../apache/beam/harness/test/TestExecutors.java | 85 ++++++++++ .../beam/harness/test/TestExecutorsTest.java | 160 ++++++++++++++++++ .../apache/beam/harness/test/TestStreams.java | 162 +++++++++++++++++++ .../beam/harness/test/TestStreamsTest.java | 84 ++++++++++ sdks/java/harness/pom.xml | 26 +++ .../org/apache/beam/fn/harness/FnHarness.java | 19 ++- .../harness/channel/ManagedChannelFactory.java | 86 ---------- .../harness/channel/SocketAddressFactory.java | 64 -------- .../beam/fn/harness/channel/package-info.java | 22 --- .../fn/harness/BeamFnDataReadRunnerTest.java | 4 +- .../apache/beam/fn/harness/FnHarnessTest.java | 2 +- .../channel/ManagedChannelFactoryTest.java | 73 --------- .../channel/SocketAddressFactoryTest.java | 56 ------- .../control/BeamFnControlClientTest.java | 2 +- .../fn/harness/control/RegisterHandlerTest.java | 4 +- ...BeamFnDataBufferingOutboundObserverTest.java | 2 +- .../harness/data/BeamFnDataGrpcClientTest.java | 2 +- .../data/BeamFnDataGrpcMultiplexerTest.java | 2 +- .../logging/BeamFnLoggingClientTest.java | 2 +- .../state/BeamFnStateGrpcClientCacheTest.java | 2 +- .../stream/BufferingStreamObserverTest.java | 6 +- .../stream/DirectStreamObserverTest.java | 6 +- .../beam/fn/harness/test/TestExecutors.java | 85 ---------- .../beam/fn/harness/test/TestExecutorsTest.java | 160 ------------------ .../beam/fn/harness/test/TestStreams.java | 162 ------------------- .../beam/fn/harness/test/TestStreamsTest.java | 84 ---------- sdks/java/pom.xml | 1 + 41 files changed, 1370 insertions(+), 818 deletions(-) ----------------------------------------------------------------------