[BEAM-1347, BEAM-1348] Beam Fn API Basic Java Harness and Proto Model This closes #1801
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/343176c0 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/343176c0 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/343176c0 Branch: refs/heads/master Commit: 343176c008832f4d3776a6e591d36be84dfb022a Parents: 582c4a8 0b4b2be Author: Luke Cwik <[email protected]> Authored: Mon Jan 30 12:48:35 2017 -0800 Committer: Luke Cwik <[email protected]> Committed: Mon Jan 30 12:48:35 2017 -0800 ---------------------------------------------------------------------- pom.xml | 36 +- runners/apex/pom.xml | 2 +- sdks/common/fn-api/pom.xml | 111 +++ .../fn-api/src/main/proto/beam_fn_api.proto | 771 +++++++++++++++++++ sdks/common/pom.xml | 38 + .../src/main/resources/beam/findbugs-filter.xml | 32 +- sdks/java/harness/pom.xml | 167 ++++ .../org/apache/beam/fn/harness/FnHarness.java | 131 ++++ .../harness/channel/ManagedChannelFactory.java | 80 ++ .../harness/channel/SocketAddressFactory.java | 64 ++ .../beam/fn/harness/channel/package-info.java | 22 + .../fn/harness/control/BeamFnControlClient.java | 165 ++++ .../harness/control/ProcessBundleHandler.java | 334 ++++++++ .../fn/harness/control/RegisterHandler.java | 92 +++ .../beam/fn/harness/control/package-info.java | 22 + .../BeamFnDataBufferingOutboundObserver.java | 135 ++++ .../beam/fn/harness/data/BeamFnDataClient.java | 64 ++ .../fn/harness/data/BeamFnDataGrpcClient.java | 122 +++ .../harness/data/BeamFnDataGrpcMultiplexer.java | 140 ++++ .../harness/data/BeamFnDataInboundObserver.java | 81 ++ .../beam/fn/harness/data/package-info.java | 22 + .../fn/harness/fake/FakeAggregatorFactory.java | 52 ++ .../beam/fn/harness/fake/FakeStepContext.java | 70 ++ .../beam/fn/harness/fake/package-info.java | 22 + .../harness/fn/CloseableThrowingConsumer.java | 23 + .../beam/fn/harness/fn/ThrowingBiFunction.java | 32 + .../beam/fn/harness/fn/ThrowingConsumer.java | 32 + .../beam/fn/harness/fn/ThrowingFunction.java | 32 + .../beam/fn/harness/fn/ThrowingRunnable.java | 30 + .../apache/beam/fn/harness/fn/package-info.java | 22 + .../fn/harness/logging/BeamFnLoggingClient.java | 308 ++++++++ .../beam/fn/harness/logging/package-info.java | 22 + .../apache/beam/fn/harness/package-info.java | 22 + .../beam/fn/harness/stream/AdvancingPhaser.java | 36 + .../harness/stream/BufferingStreamObserver.java | 166 ++++ .../fn/harness/stream/DirectStreamObserver.java | 71 ++ .../ForwardingClientResponseObserver.java | 63 ++ .../harness/stream/StreamObserverFactory.java | 91 +++ .../beam/fn/harness/stream/package-info.java | 22 + .../beam/runners/core/BeamFnDataReadRunner.java | 104 +++ .../runners/core/BeamFnDataWriteRunner.java | 87 +++ .../beam/runners/core/BoundedSourceRunner.java | 105 +++ .../apache/beam/runners/core/package-info.java | 22 + .../apache/beam/fn/harness/FnHarnessTest.java | 130 ++++ .../channel/ManagedChannelFactoryTest.java | 74 ++ .../channel/SocketAddressFactoryTest.java | 56 ++ .../control/BeamFnControlClientTest.java | 182 +++++ .../control/ProcessBundleHandlerTest.java | 674 ++++++++++++++++ .../fn/harness/control/RegisterHandlerTest.java | 80 ++ ...BeamFnDataBufferingOutboundObserverTest.java | 142 ++++ .../harness/data/BeamFnDataGrpcClientTest.java | 309 ++++++++ .../data/BeamFnDataGrpcMultiplexerTest.java | 96 +++ .../data/BeamFnDataInboundObserverTest.java | 116 +++ .../logging/BeamFnLoggingClientTest.java | 169 ++++ .../fn/harness/stream/AdvancingPhaserTest.java | 48 ++ .../stream/BufferingStreamObserverTest.java | 146 ++++ .../stream/DirectStreamObserverTest.java | 139 ++++ .../ForwardingClientResponseObserverTest.java | 60 ++ .../stream/StreamObserverFactoryTest.java | 84 ++ .../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 ++ .../runners/core/BeamFnDataReadRunnerTest.java | 187 +++++ .../runners/core/BeamFnDataWriteRunnerTest.java | 155 ++++ .../runners/core/BoundedSourceRunnerTest.java | 113 +++ sdks/java/pom.xml | 1 + sdks/pom.xml | 1 + 68 files changed, 7514 insertions(+), 4 deletions(-) ----------------------------------------------------------------------
