This closes #1624
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c1b7f869 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c1b7f869 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c1b7f869 Branch: refs/heads/master Commit: c1b7f8695a599981e549fad598f36a1559971859 Parents: fe7fc29 662934b Author: Sela <ans...@paypal.com> Authored: Tue Jan 10 19:13:37 2017 +0200 Committer: Sela <ans...@paypal.com> Committed: Tue Jan 10 19:13:37 2017 +0200 ---------------------------------------------------------------------- .../runners/spark/translation/DoFnFunction.java | 6 +- .../spark/translation/EvaluationContext.java | 34 +++-- .../translation/GroupCombineFunctions.java | 8 +- .../spark/translation/MultiDoFnFunction.java | 7 +- .../translation/SparkAbstractCombineFn.java | 12 +- .../spark/translation/SparkGlobalCombineFn.java | 13 +- .../spark/translation/SparkKeyedCombineFn.java | 13 +- .../spark/translation/SparkPCollectionView.java | 99 +++++++++++++++ .../spark/translation/TransformTranslator.java | 33 ++++- .../spark/translation/TranslationUtils.java | 37 ++++-- .../streaming/StreamingTransformTranslator.java | 75 +++++++---- .../runners/spark/util/BroadcastHelper.java | 127 ------------------- .../runners/spark/util/SideInputBroadcast.java | 77 +++++++++++ .../spark/util/SparkSideInputReader.java | 8 +- .../ResumeFromCheckpointStreamingTest.java | 18 +++ .../src/main/resources/beam/findbugs-filter.xml | 26 ---- 16 files changed, 353 insertions(+), 240 deletions(-) ----------------------------------------------------------------------