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 2016/10/10 16:33:57 UTC

crunch git commit: CRUNCH-623: Improves Javadoc of PTable#cogroup

Repository: crunch
Updated Branches:
  refs/heads/master e8d2a69b6 -> 5944f81b2


CRUNCH-623: Improves Javadoc of PTable#cogroup

Signed-off-by: Josh Wills <jw...@apache.org>


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

Branch: refs/heads/master
Commit: 5944f81b2aa15c59484d24864570d21e13bfca3b
Parents: e8d2a69
Author: Nathan Schile <na...@cerner.com>
Authored: Thu Sep 29 16:24:14 2016 -0500
Committer: Josh Wills <jw...@apache.org>
Committed: Mon Oct 10 09:28:38 2016 -0700

----------------------------------------------------------------------
 crunch-core/src/main/java/org/apache/crunch/PTable.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/crunch/blob/5944f81b/crunch-core/src/main/java/org/apache/crunch/PTable.java
----------------------------------------------------------------------
diff --git a/crunch-core/src/main/java/org/apache/crunch/PTable.java b/crunch-core/src/main/java/org/apache/crunch/PTable.java
index 74cade8..114c655 100644
--- a/crunch-core/src/main/java/org/apache/crunch/PTable.java
+++ b/crunch-core/src/main/java/org/apache/crunch/PTable.java
@@ -171,7 +171,10 @@ public interface PTable<K, V> extends PCollection<Pair<K, V>> {
   <U> PTable<K, Pair<V, U>> join(PTable<K, U> other);
 
   /**
-   * Co-group operation with the given table on common keys.
+   * Co-group operation with the given table.
+   * <p>
+   * <b>Note:</b> If the given table contains keys that are not present in this PTable, an empty
+   * PCollection is set for the relationship.
    */
   <U> PTable<K, Pair<Collection<V>, Collection<U>>> cogroup(PTable<K, U> other);