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/04/06 23:55:20 UTC
[1/2] incubator-beam git commit: Remove stdout printing from test
Repository: incubator-beam
Updated Branches:
refs/heads/master f6299519b -> 064573cba
Remove stdout printing from test
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/662df896
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/662df896
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/662df896
Branch: refs/heads/master
Commit: 662df8967aa12d847e5353f85776c1c1dd2e0dfe
Parents: 6b408b2
Author: Kenneth Knowles <kl...@google.com>
Authored: Tue Apr 5 19:17:55 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Tue Apr 5 19:17:55 2016 -0700
----------------------------------------------------------------------
.../cloud/dataflow/sdk/util/MergingActiveWindowSetTest.java | 5 -----
1 file changed, 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/662df896/sdks/java/core/src/test/java/com/google/cloud/dataflow/sdk/util/MergingActiveWindowSetTest.java
----------------------------------------------------------------------
diff --git a/sdks/java/core/src/test/java/com/google/cloud/dataflow/sdk/util/MergingActiveWindowSetTest.java b/sdks/java/core/src/test/java/com/google/cloud/dataflow/sdk/util/MergingActiveWindowSetTest.java
index 32f3c1b..6783b81 100644
--- a/sdks/java/core/src/test/java/com/google/cloud/dataflow/sdk/util/MergingActiveWindowSetTest.java
+++ b/sdks/java/core/src/test/java/com/google/cloud/dataflow/sdk/util/MergingActiveWindowSetTest.java
@@ -63,7 +63,6 @@ public class MergingActiveWindowSetTest {
}
private void add(final long instant) {
- System.out.println("ADD " + instant);
final Object element = new Long(instant);
Sessions.AssignContext context = windowFn.new AssignContext() {
@Override
@@ -88,20 +87,16 @@ public class MergingActiveWindowSetTest {
}
private void merge(ActiveWindowSet.MergeCallback<IntervalWindow> callback) throws Exception {
- System.out.println("MERGE");
set.merge(callback);
for (IntervalWindow window : set.getActiveWindows()) {
set.ensureWindowIsActive(window);
}
set.checkInvariants();
- System.out.println(set);
}
private void pruneAndPersist() {
- System.out.println("PRUNE");
set.cleanupTemporaryWindows();
set.checkInvariants();
- System.out.println(set);
set.persist();
}
[2/2] incubator-beam git commit: This closes #133
Posted by ke...@apache.org.
This closes #133
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/064573cb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/064573cb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/064573cb
Branch: refs/heads/master
Commit: 064573cbaf3486b4ee5ae82007fea57e39644106
Parents: f629951 662df89
Author: Kenneth Knowles <kl...@google.com>
Authored: Wed Apr 6 14:54:07 2016 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Wed Apr 6 14:54:07 2016 -0700
----------------------------------------------------------------------
.../cloud/dataflow/sdk/util/MergingActiveWindowSetTest.java | 5 -----
1 file changed, 5 deletions(-)
----------------------------------------------------------------------