This closes #3899: Move Runners Core Fn Api classes into a package

Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/4b7813c2
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/4b7813c2
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/4b7813c2

Branch: refs/heads/master
Commit: 4b7813c253b7946e7b11a2314b42f6fb64e4d952
Parents: 9c14d73 e9f60c4
Author: Kenneth Knowles <k...@google.com>
Authored: Fri Sep 29 09:05:30 2017 -0700
Committer: Kenneth Knowles <k...@google.com>
Committed: Fri Sep 29 09:05:30 2017 -0700

----------------------------------------------------------------------
 .../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 -----------
 .../runners/core/fn/FnApiControlClient.java     | 148 ++++++++++++++++
 .../core/fn/FnApiControlClientPoolService.java  |  66 +++++++
 .../beam/runners/core/fn/FnDataReceiver.java    |  33 ++++
 .../beam/runners/core/fn/FnDataService.java     |  81 +++++++++
 .../beam/runners/core/fn/SdkHarnessClient.java  | 172 +++++++++++++++++++
 .../runners/core/fn/SdkHarnessDoFnRunner.java   | 101 +++++++++++
 .../beam/runners/core/fn/package-info.java      |  22 +++
 .../core/FnApiControlClientPoolServiceTest.java |  65 -------
 .../runners/core/FnApiControlClientTest.java    | 139 ---------------
 .../beam/runners/core/SdkHarnessClientTest.java |  96 -----------
 .../runners/core/SdkHarnessDoFnRunnerTest.java  |  73 --------
 .../fn/FnApiControlClientPoolServiceTest.java   |  65 +++++++
 .../runners/core/fn/FnApiControlClientTest.java | 139 +++++++++++++++
 .../runners/core/fn/SdkHarnessClientTest.java   |  96 +++++++++++
 .../core/fn/SdkHarnessDoFnRunnerTest.java       |  73 ++++++++
 21 files changed, 996 insertions(+), 973 deletions(-)
----------------------------------------------------------------------


Reply via email to