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

Posted to commits@beam.apache.org by ke...@apache.org on 2016/12/14 03:04:21 UTC

[3/3] incubator-beam git commit: This closes #1578

This closes #1578


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/44b4eba5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/44b4eba5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/44b4eba5

Branch: refs/heads/master
Commit: 44b4eba51fad2fd4c33ad9467ac766d4b433f852
Parents: ce3aa65 4ffed3e
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue Dec 13 18:54:51 2016 -0800
Committer: Kenneth Knowles <kl...@google.com>
Committed: Tue Dec 13 18:54:51 2016 -0800

----------------------------------------------------------------------
 .../spark/aggregators/SparkAggregators.java     |  30 +-
 .../beam/runners/spark/examples/WordCount.java  |   6 +-
 .../runners/spark/translation/DoFnFunction.java | 110 +++---
 .../translation/GroupCombineFunctions.java      |  23 +-
 .../spark/translation/MultiDoFnFunction.java    | 135 ++++---
 .../spark/translation/SparkAssignWindowFn.java  |  69 ++++
 .../translation/SparkGroupAlsoByWindowFn.java   | 214 +++++++++++
 .../spark/translation/SparkProcessContext.java  | 385 ++++---------------
 .../spark/translation/TransformTranslator.java  |  31 +-
 .../streaming/StreamingTransformTranslator.java |  35 +-
 .../streaming/utils/PAssertStreaming.java       |  26 +-
 11 files changed, 574 insertions(+), 490 deletions(-)
----------------------------------------------------------------------