You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by am...@apache.org on 2017/01/10 17:27:19 UTC

[3/3] beam git commit: This closes #1624

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 <an...@paypal.com>
Authored: Tue Jan 10 19:13:37 2017 +0200
Committer: Sela <an...@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(-)
----------------------------------------------------------------------