public abstract class JoinerClosure extends Object
Joiner.getIterator(JoinerClosure)
implementation, or to a Buffer
via the BufferCall.getJoinerClosure()
method.
All iterators returned by getIterator(int)
may be retrieved more than once to restart them except for the left
most iterator at position 0
(zero).
This iterator may only be iterated across once. All other iterators are backed by memory and possibly disk.Modifier and Type | Field and Description |
---|---|
protected FlowProcess |
flowProcess |
protected Fields[] |
joinFields |
protected Fields[] |
valueFields |
Constructor and Description |
---|
JoinerClosure(FlowProcess flowProcess,
Fields[] joinFields,
Fields[] valueFields) |
Modifier and Type | Method and Description |
---|---|
FlowProcess |
getFlowProcess() |
abstract Tuple |
getGroupTuple(Tuple keysTuple) |
abstract Iterator<Tuple> |
getIterator(int pos)
Returns a Tuple Iterator for the given pipe position.
|
Fields[] |
getJoinFields()
Returns an array of
Fields denoting the join fields or keys uses for each incoming pipe. |
Fields[] |
getValueFields()
Returns an array of all the incoming fields for each incoming pipe.
|
abstract boolean |
isEmpty(int pos) |
boolean |
isSelfJoin() |
abstract int |
size() |
protected final FlowProcess flowProcess
protected final Fields[] joinFields
protected final Fields[] valueFields
public JoinerClosure(FlowProcess flowProcess, Fields[] joinFields, Fields[] valueFields)
public FlowProcess getFlowProcess()
public Fields[] getJoinFields()
Fields
denoting the join fields or keys uses for each incoming pipe.
The most left handed pipe will be in array position 0.public Fields[] getValueFields()
public boolean isSelfJoin()
public abstract int size()
public abstract Iterator<Tuple> getIterator(int pos)
CoGroup
.
To restart an Iterator over a given pipe, this method must be called again.pos
- of type intpublic abstract boolean isEmpty(int pos)
public abstract Tuple getGroupTuple(Tuple keysTuple)
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.