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 2016/04/19 21:40:30 UTC
[3/5] incubator-beam git commit: Replace valueInEmptyWindows with
valueInGlobalWindow
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 <an...@paypal.com>
Authored: Thu Apr 14 22:01:15 2016 +0300
Committer: Sela <an...@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