This closes #4086
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/727253ee Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/727253ee Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/727253ee Branch: refs/heads/master Commit: 727253ee3774a3ac4f2841d4276d2bc8e14dcdec Parents: 29399fd 7031159 Author: Thomas Groh <[email protected]> Authored: Wed Nov 8 16:43:43 2017 -0800 Committer: Thomas Groh <[email protected]> Committed: Wed Nov 8 16:43:43 2017 -0800 ---------------------------------------------------------------------- .../runners/core/fn/FnApiControlClient.java | 4 + .../core/fn/FnApiControlClientPoolService.java | 8 +- .../beam/runners/core/fn/FnDataReceiver.java | 4 + .../beam/runners/core/fn/FnDataService.java | 4 + .../beam/runners/core/fn/SdkHarnessClient.java | 4 + .../runners/core/fn/SdkHarnessDoFnRunner.java | 8 +- runners/java-fn-execution/pom.xml | 15 ++ .../fnexecution/control/FnApiControlClient.java | 148 ++++++++++++++++ .../control/FnApiControlClientPoolService.java | 66 +++++++ .../fnexecution/control/SdkHarnessClient.java | 173 +++++++++++++++++++ .../fnexecution/control/package-info.java | 23 +++ .../fnexecution/data/FnDataReceiver.java | 27 +++ .../runners/fnexecution/data/package-info.java | 23 +++ .../FnApiControlClientPoolServiceTest.java | 65 +++++++ .../control/FnApiControlClientTest.java | 139 +++++++++++++++ .../control/SdkHarnessClientTest.java | 96 ++++++++++ 16 files changed, 805 insertions(+), 2 deletions(-) ----------------------------------------------------------------------
