[BEAM-1347] Create a DoFnRunner specific for the Fn API This closes #3432
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/56e4251d Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/56e4251d Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/56e4251d Branch: refs/heads/master Commit: 56e4251deeb080ceff331fc4adb5d68609b04c71 Parents: f62586a 7da08c9 Author: Luke Cwik <[email protected]> Authored: Fri Jul 7 13:44:56 2017 -0700 Committer: Luke Cwik <[email protected]> Committed: Fri Jul 7 13:44:56 2017 -0700 ---------------------------------------------------------------------- sdks/java/harness/pom.xml | 10 + .../beam/runners/core/DoFnRunnerFactory.java | 182 ------ .../beam/runners/core/FnApiDoFnRunner.java | 547 +++++++++++++++++++ .../runners/core/DoFnRunnerFactoryTest.java | 209 ------- .../beam/runners/core/FnApiDoFnRunnerTest.java | 210 +++++++ 5 files changed, 767 insertions(+), 391 deletions(-) ----------------------------------------------------------------------
