cascading.flow.hadoop
Class HadoopGroupByClosure
java.lang.Object
cascading.pipe.joiner.JoinerClosure
cascading.flow.hadoop.HadoopGroupByClosure
- Direct Known Subclasses:
- HadoopCoGroupClosure
public class HadoopGroupByClosure
- extends cascading.pipe.joiner.JoinerClosure
Class GroupClosure is used internally to represent groups of tuples during grouping.
Fields inherited from class cascading.pipe.joiner.JoinerClosure |
flowProcess, joinFields, valueFields |
Constructor Summary |
HadoopGroupByClosure(cascading.flow.FlowProcess flowProcess,
cascading.tuple.Fields[] groupingFields,
cascading.tuple.Fields[] valueFields)
|
Methods inherited from class cascading.pipe.joiner.JoinerClosure |
getFlowProcess, getJoinFields, getValueFields, isSelfJoin |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
grouping
protected cascading.tuple.Tuple grouping
values
protected Iterator values
HadoopGroupByClosure
public HadoopGroupByClosure(cascading.flow.FlowProcess flowProcess,
cascading.tuple.Fields[] groupingFields,
cascading.tuple.Fields[] valueFields)
getGrouping
public cascading.tuple.Tuple getGrouping()
size
public int size()
- Specified by:
size
in class cascading.pipe.joiner.JoinerClosure
getIterator
public Iterator getIterator(int pos)
- Specified by:
getIterator
in class cascading.pipe.joiner.JoinerClosure
isEmpty
public boolean isEmpty(int pos)
- Specified by:
isEmpty
in class cascading.pipe.joiner.JoinerClosure
makeIterator
protected Iterator<cascading.tuple.Tuple> makeIterator(int pos,
Iterator values)
reset
public void reset(cascading.tuple.Tuple grouping,
Iterator values)
getGroupTuple
public cascading.tuple.Tuple getGroupTuple(cascading.tuple.Tuple keysTuple)
- Specified by:
getGroupTuple
in class cascading.pipe.joiner.JoinerClosure
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.