[BEAM-2421] Swap to use an Impulse primitive + DoFn for Create when executing with the Fn API.
This closes #3312 Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/caecac3b Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/caecac3b Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/caecac3b Branch: refs/heads/DSL_SQL Commit: caecac3b4acb5bfa6e36143d3868b2d80ab119da Parents: 609016d 1cdb80c Author: Luke Cwik <[email protected]> Authored: Wed Jun 7 13:43:38 2017 -0700 Committer: Luke Cwik <[email protected]> Committed: Wed Jun 7 13:43:38 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/dataflow/DataflowRunner.java | 154 ++++++++++++++++++- 1 file changed, 146 insertions(+), 8 deletions(-) ----------------------------------------------------------------------
