You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@crunch.apache.org by jw...@apache.org on 2013/01/26 00:42:27 UTC
git commit: CRUNCH-151: Add toString method for the Iterable type
used by PGroupedTable. Contributed by Dave Beech.
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 <jw...@apache.org>
Authored: Fri Jan 25 15:40:38 2013 -0800
Committer: Josh Wills <jw...@apache.org>
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>>> {