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.
Fields inherited from class cascading.pipe.joiner.JoinerClosure |
flowProcess, joinFields, valueFields |
Constructor Summary |
HadoopCoGroupClosure(cascading.flow.FlowProcess flowProcess,
int numSelfJoins,
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 |
HadoopCoGroupClosure
public HadoopCoGroupClosure(cascading.flow.FlowProcess flowProcess,
int numSelfJoins,
cascading.tuple.Fields[] groupingFields,
cascading.tuple.Fields[] valueFields)
size
public int size()
- Overrides:
size
in class HadoopGroupByClosure
getIterator
public Iterator<cascading.tuple.Tuple> getIterator(int pos)
- Overrides:
getIterator
in class HadoopGroupByClosure
getGroupTuple
public cascading.tuple.Tuple getGroupTuple(cascading.tuple.Tuple keysTuple)
- Overrides:
getGroupTuple
in class HadoopGroupByClosure
isEmpty
public boolean isEmpty(int pos)
- Overrides:
isEmpty
in class HadoopGroupByClosure
reset
public void reset(cascading.tuple.Tuple grouping,
Iterator values)
- Overrides:
reset
in class HadoopGroupByClosure
createIterator
public Iterator<cascading.tuple.Tuple> createIterator(cascading.tuple.io.IndexTuple current,
Iterator<cascading.tuple.io.IndexTuple> values)
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.