public abstract class AbstractRelationalJoin extends CompositeOperator
Modifier | Constructor and Description |
---|---|
protected |
AbstractRelationalJoin() |
Modifier and Type | Method and Description |
---|---|
protected void |
compose(CompositionContext ctx)
Compose the body of this operator.
|
protected abstract RecordPort |
composeJoin(CompositionContext ctx,
RecordPort left,
RecordPort right,
JoinKey[] keys) |
ScalarValuedFunction |
getJoinCondition()
If non-null, the condition is evaluated for every possible matching row.
|
JoinKey[] |
getJoinKeys()
Returns the join keys to use when performing the join.
|
RecordPort |
getLeft()
Returns the left input port.
|
RecordPort |
getOutput()
Returns the output port.
|
RecordPort |
getRight()
Returns the right input port.
|
boolean |
getUseHashJoinHint()
Returns whether to perform the join as a hash join.
|
protected int |
newJoinID() |
void |
setJoinCondition(ScalarValuedFunction joinCondition)
Sets the join condition.
|
void |
setJoinCondition(String joinCondition)
Sets the join condition.
|
void |
setJoinKeys(JoinKey[] joinKeys)
Sets the join keys to use when performing the join.
|
void |
setJoinKeys(List<JoinKey> joinKeys)
Sets the join keys to use when performing the join.
|
void |
setJoinKeys(String[] keyFieldNames)
Sets the join keys to use when performing the join.
|
void |
setJoinKeys(String[] leftKeyFieldNames,
String[] rightKeyFieldNames)
Sets the join keys to use when performing the join.
|
void |
setUseHashJoinHint(boolean useHashJoinHint)
Sets whether to perform the join as a hash join.
|
disableParallelism, getInputPorts, getOutputPorts, newInput, newInput, newOutput, newRecordInput, newRecordInput, newRecordOutput, notifyError
public RecordPort getLeft()
public RecordPort getRight()
public RecordPort getOutput()
public final ScalarValuedFunction getJoinCondition()
public final void setJoinCondition(ScalarValuedFunction joinCondition)
joinCondition
- the join conditionpublic final void setJoinCondition(String joinCondition)
joinCondition
- a predicate expression in SQL-like syntax parsed into the join conditionpublic final boolean getUseHashJoinHint()
public final void setUseHashJoinHint(boolean useHashJoinHint)
useHashJoinHint
- whether to perform the join as a hash joinpublic final JoinKey[] getJoinKeys()
public final void setJoinKeys(JoinKey[] joinKeys)
joinKeys
- the join keys to use when performing the join.public final void setJoinKeys(String[] keyFieldNames)
keyFieldNames
- the join keys to use when performing the join.public final void setJoinKeys(List<JoinKey> joinKeys)
joinKeys
- the join keys to use when performing the join.public final void setJoinKeys(String[] leftKeyFieldNames, String[] rightKeyFieldNames)
leftKeyFieldNames
- the left join keys to use when performing the join.rightKeyFieldNames
- the right join keys to use when performing the join.protected final int newJoinID()
protected abstract RecordPort composeJoin(CompositionContext ctx, RecordPort left, RecordPort right, JoinKey[] keys)
protected void compose(CompositionContext ctx)
CompositeOperator
OperatorComposable.add(O)
OperatorComposable.connect(P, P)
. This includes
connections from the composite's input ports to sub-operators, connections between sub-operators, and
connections from sub-operators output ports to the composite's output portscompose
in class CompositeOperator
ctx
- the contextCopyright © 2016 Actian Corporation. All rights reserved.