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 <aviem...@gmail.com> Authored: Sat Jun 3 17:42:48 2017 +0300 Committer: Aviem Zur <aviem...@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(-) ----------------------------------------------------------------------