public class MemoryCoGroupClosure extends JoinerClosure
flowProcess, joinFields, valueFields
Constructor and Description |
---|
MemoryCoGroupClosure(FlowProcess flowProcess,
int numSelfJoins,
Fields[] groupingFields,
Fields[] valueFields) |
Modifier and Type | Method and Description |
---|---|
Tuple |
getGroupTuple(Tuple keysTuple) |
Iterator<Tuple> |
getIterator(int pos)
Returns a Tuple Iterator for the given pipe position.
|
boolean |
isEmpty(int pos) |
void |
reset(Collection<Tuple>[] collections) |
int |
size() |
getFlowProcess, getJoinFields, getValueFields, isSelfJoin
public MemoryCoGroupClosure(FlowProcess flowProcess, int numSelfJoins, Fields[] groupingFields, Fields[] valueFields)
public int size()
size
in class JoinerClosure
public void reset(Collection<Tuple>[] collections)
public Iterator<Tuple> getIterator(int pos)
JoinerClosure
CoGroup
.
To restart an Iterator over a given pipe, this method must be called again.getIterator
in class JoinerClosure
pos
- of type intpublic boolean isEmpty(int pos)
isEmpty
in class JoinerClosure
public Tuple getGroupTuple(Tuple keysTuple)
getGroupTuple
in class JoinerClosure
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.