Replace valueInEmptyWindows with valueInGlobalWindow
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5fab1c5f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5fab1c5f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/5fab1c5f Branch: refs/heads/master Commit: 5fab1c5f828395024ff4add85a174ffdfbfce916 Parents: f20bf8a Author: Sela <ans...@paypal.com> Authored: Thu Apr 14 22:01:15 2016 +0300 Committer: Sela <ans...@paypal.com> Committed: Tue Apr 19 22:06:15 2016 +0300 ---------------------------------------------------------------------- .../org/apache/beam/runners/spark/translation/DoFnFunction.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/5fab1c5f/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/DoFnFunction.java ---------------------------------------------------------------------- diff --git a/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/DoFnFunction.java b/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/DoFnFunction.java index 674da73..fbc9e98 100644 --- a/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/DoFnFunction.java +++ b/runners/spark/src/main/java/org/apache/beam/runners/spark/translation/DoFnFunction.java @@ -75,7 +75,7 @@ public class DoFnFunction<I, O> implements FlatMapFunction<Iterator<WindowedValu @Override public synchronized void output(O o) { outputs.add(windowedValue != null ? windowedValue.withValue(o) : - WindowedValue.valueInEmptyWindows(o)); + WindowedValue.valueInGlobalWindow(o)); } @Override
