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