[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 <[email protected]> Authored: Wed Nov 22 16:17:08 2017 -0800 Committer: Luke Cwik <[email protected]> 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(-) ----------------------------------------------------------------------
