This closes #1162
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/53fe3ee4 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/53fe3ee4 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/53fe3ee4 Branch: refs/heads/python-sdk Commit: 53fe3ee425163a76b69d0830449d222d925eb9cd Parents: f2fe1ae a54ded3 Author: Sela <ans...@paypal.com> Authored: Wed Oct 26 10:01:51 2016 +0300 Committer: Sela <ans...@paypal.com> Committed: Wed Oct 26 10:01:51 2016 +0300 ---------------------------------------------------------------------- .../apache/beam/runners/spark/SparkRunner.java | 19 ------ .../translation/GroupCombineFunctions.java | 66 +++++++++----------- .../spark/translation/TransformTranslator.java | 43 +++---------- .../streaming/StreamingTransformTranslator.java | 65 +++++-------------- .../spark/util/SparkSideInputReader.java | 2 +- 5 files changed, 55 insertions(+), 140 deletions(-) ----------------------------------------------------------------------