cascading.flow.hadoop
Class HadoopCoGroupClosure
java.lang.Object
cascading.pipe.joiner.JoinerClosure
cascading.flow.hadoop.HadoopGroupByClosure
cascading.flow.hadoop.HadoopCoGroupClosure
public class HadoopCoGroupClosure
- extends HadoopGroupByClosure
Class CoGroupClosure is used internally to represent co-grouping results of multiple tuple streams.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HadoopCoGroupClosure
public HadoopCoGroupClosure(FlowProcess flowProcess,
int numSelfJoins,
Fields[] groupingFields,
Fields[] valueFields)
size
public int size()
- Overrides:
size
in class HadoopGroupByClosure
getIterator
public Iterator<Tuple> getIterator(int pos)
- Overrides:
getIterator
in class HadoopGroupByClosure
getGroupTuple
public Tuple getGroupTuple(Tuple keysTuple)
- Overrides:
getGroupTuple
in class HadoopGroupByClosure
isEmpty
public boolean isEmpty(int pos)
- Overrides:
isEmpty
in class HadoopGroupByClosure
reset
public void reset(Tuple grouping,
Iterator values)
- Overrides:
reset
in class HadoopGroupByClosure
createIterator
public Iterator<Tuple> createIterator(IndexTuple current,
Iterator<IndexTuple> values)
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.