cascading.pipe.cogroup
Class GroupClosure

java.lang.Object
  cascading.pipe.cogroup.GroupClosure

Direct Known Subclasses:

CoGroupClosure

public class GroupClosure
extends Object

Class GroupClosure is used internally to represent groups of tuples during grouping.

Constructor Summary

GroupClosure(Fields[] groupingFields, Fields[] valueFields, Tuple key, Iterator values)

Method Summary

Tuple	getGrouping()
Iterator	getIterator(int pos)
protected Iterator<Tuple>	makeIterator(int pos, Iterator values)
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupClosure

public GroupClosure(Fields[] groupingFields,
                    Fields[] valueFields,
                    Tuple key,
                    Iterator values)

Method Detail

size

public int size()

getGrouping

public Tuple getGrouping()

getIterator

public Iterator getIterator(int pos)

makeIterator

protected Iterator<Tuple> makeIterator(int pos,
                                       Iterator values)