crunch-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gr...@apache.org
Subject git commit: CRUNCH-169 Use a single reducer in Aggregate.min
Date Mon, 25 Feb 2013 16:58:32 GMT
Updated Branches:
  refs/heads/master 855b0ddcb -> c0564f181


CRUNCH-169 Use a single reducer in Aggregate.min


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

Branch: refs/heads/master
Commit: c0564f181fdd7eb1d4e6f6a82a4fa7bdcc9a0680
Parents: 855b0dd
Author: Gabriel Reid <greid@apache.org>
Authored: Mon Feb 25 17:55:57 2013 +0100
Committer: Gabriel Reid <greid@apache.org>
Committed: Mon Feb 25 17:55:57 2013 +0100

----------------------------------------------------------------------
 .../main/java/org/apache/crunch/lib/Aggregate.java |    2 +-
 1 files changed, 1 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/crunch/blob/c0564f18/crunch/src/main/java/org/apache/crunch/lib/Aggregate.java
----------------------------------------------------------------------
diff --git a/crunch/src/main/java/org/apache/crunch/lib/Aggregate.java b/crunch/src/main/java/org/apache/crunch/lib/Aggregate.java
index 1c7ac80..d4109cc 100644
--- a/crunch/src/main/java/org/apache/crunch/lib/Aggregate.java
+++ b/crunch/src/main/java/org/apache/crunch/lib/Aggregate.java
@@ -234,7 +234,7 @@ public class Aggregate {
               emitter.emit(Pair.of(false, min));
             }
           }
-        }, tf.tableOf(tf.booleans(), collect.getPType())).groupByKey()
+        }, tf.tableOf(tf.booleans(), collect.getPType())).groupByKey(1)
         .combineValues(new CombineFn<Boolean, S>() {
           public void process(Pair<Boolean, Iterable<S>> input, Emitter<Pair<Boolean,
S>> emitter) {
             S min = null;


Mime
View raw message