cascading.flow.stream
Class MemoryCoGroupClosure
java.lang.Object
cascading.pipe.joiner.JoinerClosure
cascading.flow.stream.MemoryCoGroupClosure
public class MemoryCoGroupClosure
- extends JoinerClosure
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MemoryCoGroupClosure
public MemoryCoGroupClosure(FlowProcess flowProcess,
int numSelfJoins,
Fields[] groupingFields,
Fields[] valueFields)
size
public int size()
- Specified by:
size
in class JoinerClosure
reset
public void reset(Collection<Tuple>[] collections)
getIterator
public Iterator<Tuple> getIterator(int pos)
- Description copied from class:
JoinerClosure
- Returns a Tuple Iterator for the given pipe position. Position 0 is the most left handed pipe passed to the prior
CoGroup
.
To restart an Iterator over a given pipe, this method must be called again.
- Specified by:
getIterator
in class JoinerClosure
- Parameters:
pos
- of type int
- Returns:
- an Iterator of Tuple instances.
isEmpty
public boolean isEmpty(int pos)
- Specified by:
isEmpty
in class JoinerClosure
getGroupTuple
public Tuple getGroupTuple(Tuple keysTuple)
- Specified by:
getGroupTuple
in class JoinerClosure
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.