You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/11/07 16:54:38 UTC
[22/50] [abbrv] beam git commit: This closes #3986
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(-)
----------------------------------------------------------------------