cascading.flow.hadoop
Class HadoopGroupByClosure

java.lang.Object
  extended by cascading.pipe.joiner.JoinerClosure
      extended by 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.


Field Summary
protected  cascading.tuple.Tuple grouping
           
protected  Iterator values
           
 
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)
           
 
Method Summary
 cascading.tuple.Tuple getGrouping()
           
 cascading.tuple.Tuple getGroupTuple(cascading.tuple.Tuple keysTuple)
           
 Iterator getIterator(int pos)
           
 boolean isEmpty(int pos)
           
protected  Iterator<cascading.tuple.Tuple> makeIterator(int pos, Iterator values)
           
 void reset(cascading.tuple.Tuple grouping, Iterator values)
           
 int size()
           
 
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
 

Field Detail

grouping

protected cascading.tuple.Tuple grouping

values

protected Iterator values
Constructor Detail

HadoopGroupByClosure

public HadoopGroupByClosure(cascading.flow.FlowProcess flowProcess,
                            cascading.tuple.Fields[] groupingFields,
                            cascading.tuple.Fields[] valueFields)
Method Detail

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.