public class JoinSpec extends Object
This class corresponds to Join
rel node.
Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_FILTER_NULLS |
static String |
FIELD_NAME_JOIN_TYPE |
static String |
FIELD_NAME_LEFT_KEYS |
static String |
FIELD_NAME_NON_EQUI_CONDITION |
static String |
FIELD_NAME_RIGHT_KEYS |
Constructor and Description |
---|
JoinSpec(FlinkJoinType joinType,
int[] leftKeys,
int[] rightKeys,
boolean[] filterNulls,
org.apache.calcite.rex.RexNode nonEquiCondition) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
boolean[] |
getFilterNulls() |
int |
getJoinKeySize()
Gets number of keys in join key.
|
FlinkJoinType |
getJoinType() |
int[] |
getLeftKeys() |
Optional<org.apache.calcite.rex.RexNode> |
getNonEquiCondition() |
int[] |
getRightKeys() |
int |
hashCode() |
public static final String FIELD_NAME_JOIN_TYPE
public static final String FIELD_NAME_LEFT_KEYS
public static final String FIELD_NAME_RIGHT_KEYS
public static final String FIELD_NAME_FILTER_NULLS
public static final String FIELD_NAME_NON_EQUI_CONDITION
public JoinSpec(FlinkJoinType joinType, int[] leftKeys, int[] rightKeys, boolean[] filterNulls, @Nullable org.apache.calcite.rex.RexNode nonEquiCondition)
public FlinkJoinType getJoinType()
public int[] getLeftKeys()
public int[] getRightKeys()
public boolean[] getFilterNulls()
public Optional<org.apache.calcite.rex.RexNode> getNonEquiCondition()
public int getJoinKeySize()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.