[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 <[email protected]> Authored: Tue Apr 19 22:31:07 2016 +0300 Committer: Sela <[email protected]> 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(-) ----------------------------------------------------------------------
