cascading.pipe.cogroup
Class CoGroupClosure

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

public class CoGroupClosure
extends GroupClosure

Class CoGroupClosure ...

Field Summary

static String

SPILL_THRESHOLD

Constructor Summary

CoGroupClosure(JobConf jobConf, int repeat, Fields[] groupingFields, Fields[] valueFields, Tuple key, Iterator values)

Method Summary

void	build(JobConf jobConf, int repeat)
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(JobConf jobConf,
                      int repeat,
                      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(JobConf jobConf,
                  int repeat)