[3/3] beam git commit: This closes #4086

[tg...@apache.org]

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 <tg...@google.com>
Authored: Wed Nov 8 16:43:43 2017 -0800
Committer: Thomas Groh <tg...@google.com>
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(-)
----------------------------------------------------------------------