You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by av...@apache.org on 2017/06/03 14:43:12 UTC
[2/2] beam git commit: This closes #2917
This closes #2917
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/43c44232
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/43c44232
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/43c44232
Branch: refs/heads/master
Commit: 43c44232dcb23dc8ff38a05197962dbe1a3a5e64
Parents: 9cdae6c 5e5fbed
Author: Aviem Zur <av...@gmail.com>
Authored: Sat Jun 3 17:42:48 2017 +0300
Committer: Aviem Zur <av...@gmail.com>
Committed: Sat Jun 3 17:42:48 2017 +0300
----------------------------------------------------------------------
runners/spark/pom.xml | 2 -
.../spark/translation/MultiDoFnFunction.java | 104 +++++++++++++++++--
.../spark/translation/SparkProcessContext.java | 23 +++-
.../spark/translation/TransformTranslator.java | 84 ++++++++++++---
.../streaming/StreamingTransformTranslator.java | 3 +-
5 files changed, 189 insertions(+), 27 deletions(-)
----------------------------------------------------------------------