You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2016/03/03 23:08:03 UTC
[1/2] incubator-beam git commit: [BEAM-80] Swap the order of timers
and elements sent to ReduceFnRunner
Repository: incubator-beam
Updated Branches:
refs/heads/master 7582212f5 -> 5e8250411
[BEAM-80] Swap the order of timers and elements sent to ReduceFnRunner
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a359409c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a359409c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a359409c
Branch: refs/heads/master
Commit: a359409c256109b50f236761e03a52cfd1a32340
Parents: 211e76a
Author: Pei He <pe...@google.com>
Authored: Wed Mar 2 13:36:23 2016 -0800
Committer: Pei He <pe...@gmail.com>
Committed: Wed Mar 2 14:48:05 2016 -0800
----------------------------------------------------------------------
.../cloud/dataflow/sdk/util/GroupAlsoByWindowViaWindowSetDoFn.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a359409c/sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowViaWindowSetDoFn.java
----------------------------------------------------------------------
diff --git a/sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowViaWindowSetDoFn.java b/sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowViaWindowSetDoFn.java
index f6246d1..89a4fcb 100644
--- a/sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowViaWindowSetDoFn.java
+++ b/sdk/src/main/java/com/google/cloud/dataflow/sdk/util/GroupAlsoByWindowViaWindowSetDoFn.java
@@ -80,10 +80,10 @@ public class GroupAlsoByWindowViaWindowSetDoFn<
reduceFn,
c.getPipelineOptions());
+ reduceFnRunner.processElements(element.elementsIterable());
for (TimerData timer : element.timersIterable()) {
reduceFnRunner.onTimer(timer);
}
- reduceFnRunner.processElements(element.elementsIterable());
reduceFnRunner.persist();
}
[2/2] incubator-beam git commit: Closes #9
Posted by ke...@apache.org.
Closes #9
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5e825041
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5e825041
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/5e825041
Branch: refs/heads/master
Commit: 5e825041153d84c0e0e737a478d99c6b2839b096
Parents: 7582212 a359409
Author: Kenneth Knowles <kl...@google.com>
Authored: Thu Mar 3 14:06:16 2016 -0800
Committer: Kenneth Knowles <kl...@google.com>
Committed: Thu Mar 3 14:06:16 2016 -0800
----------------------------------------------------------------------
.../cloud/dataflow/sdk/util/GroupAlsoByWindowViaWindowSetDoFn.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------