You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2017/06/08 01:35:36 UTC
[47/50] beam git commit: [BEAM-2421] Swap to use an Impulse primitive
+ DoFn for Create when executing with the Fn API.
[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 <lc...@google.com>
Authored: Wed Jun 7 13:43:38 2017 -0700
Committer: Luke Cwik <lc...@google.com>
Committed: Wed Jun 7 13:43:38 2017 -0700
----------------------------------------------------------------------
.../beam/runners/dataflow/DataflowRunner.java | 154 ++++++++++++++++++-
1 file changed, 146 insertions(+), 8 deletions(-)
----------------------------------------------------------------------