This project has retired. For details please refer to its Attic page.

org.apache.crunch.lib
Class Cogroup

java.lang.Object
  org.apache.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

equals, 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.