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/01/30 20:48:57 UTC
[6/6] beam git commit: [BEAM-1347,
BEAM-1348] Beam Fn API Basic Java Harness and Proto Model
[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 <lc...@google.com>
Authored: Mon Jan 30 12:48:35 2017 -0800
Committer: Luke Cwik <lc...@google.com>
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(-)
----------------------------------------------------------------------