beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amits...@apache.org
Subject [5/5] incubator-beam git commit: [BEAM-189] The Spark runner uses valueInEmptyWindow which causes values to be dropped
Date Tue, 19 Apr 2016 19:40:32 GMT
[BEAM-189] The Spark runner uses valueInEmptyWindow which causes values to be dropped

This closes #179


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

Branch: refs/heads/master
Commit: 135cb733f94586b9dfc0c80d50979c1bfc91ba97
Parents: f20bf8a 932e5b4
Author: Sela <ansela@paypal.com>
Authored: Tue Apr 19 22:31:07 2016 +0300
Committer: Sela <ansela@paypal.com>
Committed: Tue Apr 19 22:31:07 2016 +0300

----------------------------------------------------------------------
 .../runners/spark/translation/DoFnFunction.java |  2 +-
 .../spark/translation/EvaluationContext.java    | 59 ++++++++++----------
 .../spark/translation/WindowingHelpers.java     | 38 +++++++++++--
 .../beam/runners/spark/SimpleWordCountTest.java | 35 +++++++++++-
 4 files changed, 97 insertions(+), 37 deletions(-)
----------------------------------------------------------------------



Mime
View raw message