com.cloudera.crunch.lib
Class Cogroup

java.lang.Object
  com.cloudera.crunch.lib.Cogroup

public class Cogroup
extends Object

Constructor Summary

Cogroup()

Method Summary

static <K,U,V> PTable<K,Pair<Collection<U>,Collection<V>>>

cogroup(PTable<K,U> left, PTable<K,V> right) Co-groups the two PTable arguments.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Cogroup

public Cogroup()

Method Detail

cogroup

public static <K,U,V> PTable<K,Pair<Collection<U>,Collection<V>>> cogroup(PTable<K,U> left,
                                                                          PTable<K,V> right)

Co-groups the two PTable arguments.

Returns:

a PTable representing the co-grouped tables.