Updated Branches: refs/heads/master 6a36ce61d -> 5cf8142ae
CRUNCH-151: Add toString method for the Iterable type used by PGroupedTable. Contributed by Dave Beech. Project: http://git-wip-us.apache.org/repos/asf/incubator-crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-crunch/commit/5cf8142a Tree: http://git-wip-us.apache.org/repos/asf/incubator-crunch/tree/5cf8142a Diff: http://git-wip-us.apache.org/repos/asf/incubator-crunch/diff/5cf8142a Branch: refs/heads/master Commit: 5cf8142aead9f4e168417afd3e29b6c899152edf Parents: 6a36ce6 Author: Josh Wills <[email protected]> Authored: Fri Jan 25 15:40:38 2013 -0800 Committer: Josh Wills <[email protected]> Committed: Fri Jan 25 15:40:38 2013 -0800 ---------------------------------------------------------------------- .../org/apache/crunch/types/PGroupedTableType.java | 7 +++++++ 1 files changed, 7 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/5cf8142a/crunch/src/main/java/org/apache/crunch/types/PGroupedTableType.java ---------------------------------------------------------------------- diff --git a/crunch/src/main/java/org/apache/crunch/types/PGroupedTableType.java b/crunch/src/main/java/org/apache/crunch/types/PGroupedTableType.java index 5718619..c222c89 100644 --- a/crunch/src/main/java/org/apache/crunch/types/PGroupedTableType.java +++ b/crunch/src/main/java/org/apache/crunch/types/PGroupedTableType.java @@ -29,6 +29,8 @@ import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.Path; import org.apache.hadoop.mapreduce.Job; +import com.google.common.collect.Iterables; + /** * The {@code PType} instance for {@link PGroupedTable} instances. Its settings * are derived from the {@code PTableType} that was grouped to create the @@ -63,6 +65,11 @@ public abstract class PGroupedTableType<K, V> implements PType<Pair<K, Iterable< } }; } + + @Override + public String toString() { + return Iterables.toString(this); + } } public static class PairIterableMapFn<K, V> extends MapFn<Pair<Object, Iterable<Object>>, Pair<K, Iterable<V>>> {
