You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2017/11/23 00:17:25 UTC
[4/4] beam git commit: [BEAM-2899] Migrate Stream Control to the
fn-execution module
[BEAM-2899] Migrate Stream Control to the fn-execution module
This closes #4111
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4847d34d
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4847d34d
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4847d34d
Branch: refs/heads/master
Commit: 4847d34d7dc3f8ad5e9195bd56045a7b093aa568
Parents: 5c74022 f9e2be9
Author: Luke Cwik <lc...@google.com>
Authored: Wed Nov 22 16:17:08 2017 -0800
Committer: Luke Cwik <lc...@google.com>
Committed: Wed Nov 22 16:17:08 2017 -0800
----------------------------------------------------------------------
runners/java-fn-execution/pom.xml | 29 ---
.../beam/runners/fnexecution/ServerFactory.java | 2 +-
.../runners/fnexecution/ServerFactoryTest.java | 6 +-
sdks/java/fn-execution/build.gradle | 10 +-
sdks/java/fn-execution/pom.xml | 49 ++--
.../harness/channel/ManagedChannelFactory.java | 82 ------
.../harness/channel/SocketAddressFactory.java | 64 -----
.../beam/harness/channel/package-info.java | 22 --
.../sdk/fn/channel/ManagedChannelFactory.java | 82 ++++++
.../sdk/fn/channel/SocketAddressFactory.java | 64 +++++
.../beam/sdk/fn/channel/package-info.java | 22 ++
.../beam/sdk/fn/stream/AdvancingPhaser.java | 36 +++
.../sdk/fn/stream/BufferingStreamObserver.java | 171 +++++++++++++
.../apache/beam/sdk/fn/stream/DataStreams.java | 249 +++++++++++++++++++
.../sdk/fn/stream/DirectStreamObserver.java | 71 ++++++
.../ForwardingClientResponseObserver.java | 68 +++++
.../apache/beam/sdk/fn/stream/package-info.java | 22 ++
.../channel/ManagedChannelFactoryTest.java | 71 ------
.../channel/SocketAddressFactoryTest.java | 56 -----
.../org/apache/beam/harness/test/Consumer.java | 26 --
.../org/apache/beam/harness/test/Supplier.java | 26 --
.../apache/beam/harness/test/TestExecutors.java | 93 -------
.../beam/harness/test/TestExecutorsTest.java | 175 -------------
.../apache/beam/harness/test/TestStreams.java | 185 --------------
.../beam/harness/test/TestStreamsTest.java | 109 --------
.../fn/channel/ManagedChannelFactoryTest.java | 71 ++++++
.../fn/channel/SocketAddressFactoryTest.java | 56 +++++
.../beam/sdk/fn/stream/AdvancingPhaserTest.java | 53 ++++
.../fn/stream/BufferingStreamObserverTest.java | 155 ++++++++++++
.../beam/sdk/fn/stream/DataStreamsTest.java | 167 +++++++++++++
.../sdk/fn/stream/DirectStreamObserverTest.java | 145 +++++++++++
.../ForwardingClientResponseObserverTest.java | 60 +++++
.../org/apache/beam/sdk/fn/test/Consumer.java | 26 ++
.../org/apache/beam/sdk/fn/test/Supplier.java | 26 ++
.../apache/beam/sdk/fn/test/TestExecutors.java | 93 +++++++
.../beam/sdk/fn/test/TestExecutorsTest.java | 175 +++++++++++++
.../apache/beam/sdk/fn/test/TestStreams.java | 185 ++++++++++++++
.../beam/sdk/fn/test/TestStreamsTest.java | 109 ++++++++
.../org/apache/beam/fn/harness/FnHarness.java | 2 +-
.../beam/fn/harness/state/BagUserState.java | 2 +-
.../beam/fn/harness/stream/AdvancingPhaser.java | 36 ---
.../harness/stream/BufferingStreamObserver.java | 166 -------------
.../beam/fn/harness/stream/DataStreams.java | 229 -----------------
.../fn/harness/stream/DirectStreamObserver.java | 71 ------
.../ForwardingClientResponseObserver.java | 63 -----
.../harness/stream/StreamObserverFactory.java | 20 +-
.../fn/harness/BeamFnDataReadRunnerTest.java | 4 +-
.../apache/beam/fn/harness/FnHarnessTest.java | 4 +-
.../control/BeamFnControlClientTest.java | 2 +-
.../fn/harness/control/RegisterHandlerTest.java | 4 +-
...BeamFnDataBufferingOutboundObserverTest.java | 2 +-
.../harness/data/BeamFnDataGrpcClientTest.java | 4 +-
.../data/BeamFnDataGrpcMultiplexerTest.java | 2 +-
.../logging/BeamFnLoggingClientTest.java | 2 +-
.../state/BeamFnStateGrpcClientCacheTest.java | 2 +-
.../fn/harness/stream/AdvancingPhaserTest.java | 48 ----
.../stream/BufferingStreamObserverTest.java | 146 -----------
.../beam/fn/harness/stream/DataStreamsTest.java | 167 -------------
.../stream/DirectStreamObserverTest.java | 139 -----------
.../ForwardingClientResponseObserverTest.java | 60 -----
.../stream/StreamObserverFactoryTest.java | 3 +
61 files changed, 2160 insertions(+), 2129 deletions(-)
----------------------------------------------------------------------