cascading.pipe.cogroup
Class CoGroupClosure

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

public class CoGroupClosure
extends GroupClosure

Class CoGroupClosure is used internally to represent co-grouping results of multiple tuple streams.

Field Summary

static String

SPILL_THRESHOLD

Constructor Summary

CoGroupClosure(FlowProcess flowProcess, int numSelfJoins, Fields[] groupingFields, Fields[] valueFields, Tuple key, Iterator values)

Method Summary

void	build(FlowProcess flowProcess, int numSelfJoins)
SpillableTupleList	getGroup(int pos)
Iterator<Tuple>	getIterator(int pos)
int	size()

Methods inherited from class cascading.pipe.cogroup.GroupClosure

getGrouping, makeIterator

Methods inherited from class java.lang.Object

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

Field Detail

SPILL_THRESHOLD

public static final String SPILL_THRESHOLD

See Also:

Constant Field Values

Constructor Detail

CoGroupClosure

public CoGroupClosure(FlowProcess flowProcess,
                      int numSelfJoins,
                      Fields[] groupingFields,
                      Fields[] valueFields,
                      Tuple key,
                      Iterator values)

Method Detail

size

public int size()

Overrides:

size in class GroupClosure

getIterator

public Iterator<Tuple> getIterator(int pos)

Overrides:

getIterator in class GroupClosure

getGroup

public SpillableTupleList getGroup(int pos)

build

public void build(FlowProcess flowProcess,
                  int numSelfJoins)