beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [1/2] incubator-beam git commit: Output InProcessGroupByKeyOnly elements in the Global Window
Date Tue, 26 Apr 2016 20:27:11 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master 7dc1a4047 -> 9746f0d1d


Output InProcessGroupByKeyOnly elements in the Global Window

This ensures that the values are not dropped if they are exploded (for
example, in the Watermark Manager).


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

Branch: refs/heads/master
Commit: a9e0f01748e00124d4851106cfa85da386f4531e
Parents: 7dc1a40
Author: Thomas Groh <tgroh@google.com>
Authored: Tue Apr 26 11:46:26 2016 -0700
Committer: Thomas Groh <tgroh@google.com>
Committed: Tue Apr 26 11:46:26 2016 -0700

----------------------------------------------------------------------
 .../beam/sdk/runners/inprocess/GroupByKeyEvaluatorFactory.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a9e0f017/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/inprocess/GroupByKeyEvaluatorFactory.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/inprocess/GroupByKeyEvaluatorFactory.java
b/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/inprocess/GroupByKeyEvaluatorFactory.java
index ec0af8d..4cec841 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/inprocess/GroupByKeyEvaluatorFactory.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/runners/inprocess/GroupByKeyEvaluatorFactory.java
@@ -149,7 +149,7 @@ class GroupByKeyEvaluatorFactory implements TransformEvaluatorFactory
{
             KeyedWorkItems.elementsWorkItem(key, groupedEntry.getValue());
         UncommittedBundle<KeyedWorkItem<K, V>> bundle =
             evaluationContext.createKeyedBundle(inputBundle, key, application.getOutput());
-        bundle.add(WindowedValue.valueInEmptyWindows(groupedKv));
+        bundle.add(WindowedValue.valueInGlobalWindow(groupedKv));
         resultBuilder.addOutput(bundle);
       }
       return resultBuilder.build();


Mime
View raw message