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 <[email protected]> Authored: Mon Feb 25 17:55:57 2013 +0100 Committer: Gabriel Reid <[email protected]> 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;
