Merge remote-tracking branch 'github/pr/3750' into HEAD * github/pr/3750: Add SdkHarnessDoFnRunner Higher-level SdkHarnessClient Service for pooling incoming Fn API control plane connections FnApiControlClient, de-inverts Fn API control plane Basic Java wrapper for Fn API data plane
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/8b540d2d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/8b540d2d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/8b540d2d Branch: refs/heads/master Commit: 8b540d2dd43af2a0495884d8152472a7ebff8a8e Parents: c3bcd4b 0388de1 Author: Kenneth Knowles <k...@google.com> Authored: Sun Sep 3 19:44:32 2017 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Sun Sep 3 19:44:32 2017 -0700 ---------------------------------------------------------------------- runners/core-java/pom.xml | 27 ++- .../beam/runners/core/FnApiControlClient.java | 148 ++++++++++++++++ .../core/FnApiControlClientPoolService.java | 66 +++++++ .../beam/runners/core/FnDataReceiver.java | 33 ++++ .../apache/beam/runners/core/FnDataService.java | 81 +++++++++ .../beam/runners/core/SdkHarnessClient.java | 172 +++++++++++++++++++ .../beam/runners/core/SdkHarnessDoFnRunner.java | 100 +++++++++++ .../core/FnApiControlClientPoolServiceTest.java | 65 +++++++ .../runners/core/FnApiControlClientTest.java | 139 +++++++++++++++ .../beam/runners/core/SdkHarnessClientTest.java | 96 +++++++++++ .../runners/core/SdkHarnessDoFnRunnerTest.java | 73 ++++++++ 11 files changed, 993 insertions(+), 7 deletions(-) ----------------------------------------------------------------------
