public class NestedLoopsJoin extends PhysicalJoin
LEFT, RIGHT
tupleCounter
Constructor and Description |
---|
NestedLoopsJoin(Operator left,
Operator right,
StorageManager sm,
Predicate predicate)
Constructs a new nested loops join operator.
|
Modifier and Type | Method and Description |
---|---|
protected void |
cleanup()
Cleanup after the join.
|
protected java.util.List<Tuple> |
innerGetNext()
Inner method to propagate a tuple.
|
protected java.util.List<Tuple> |
innerProcessTuple(Tuple tuple,
int inOp)
The inner tuple processing method -- all operators should implement
this.
|
protected void |
setup()
Sets up a nested loops join operator.
|
protected java.lang.String |
toStringSingle()
Textual representation.
|
combineTuples, getPredicate, getStorageManager, setOutputRelation
allDone, getInputOperator, getMultiNext, getNext, getNumberOfInputs, getOutputRelation, prefix, processTuple, setInputs, toString, toString, tuples
public NestedLoopsJoin(Operator left, Operator right, StorageManager sm, Predicate predicate) throws EngineException
left
- the left input operator.right
- the right input operator.sm
- the storage manager.predicate
- the predicate evaluated by this join operator.EngineException
- thrown whenever the operator cannot be
properly constructed.protected void setup() throws EngineException
setup
in class Operator
EngineException
- thrown whenever there is something
wrong with setting this operator up.protected void cleanup() throws EngineException
cleanup
in class Operator
EngineException
- whenever the operator cannot clean up
after itself.protected java.util.List<Tuple> innerGetNext() throws EngineException
innerGetNext
in class Operator
EngineException
- thrown whenever there is an error in
execution.protected java.util.List<Tuple> innerProcessTuple(Tuple tuple, int inOp) throws EngineException
Operator
innerProcessTuple
in class Operator
tuple
- the tuple to be processed.inOp
- the index of the input operator the tuple to be
processed belongs to.EngineException
- thrown whenever there is something wrong
with processing the tuple.protected java.lang.String toStringSingle()
toStringSingle
in class Operator