public class BeamCoGBKJoinRule
extends org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptRule
LogicalJoin
node to BeamCoGBKJoinRel
node.
This rule is matched when both the inputs to LogicalJoin
node have the same
Boundedness i.e. either when both the inputs are PCollection.IsBounded.BOUNDED
or when
both the inputs are PCollection.IsBounded.UNBOUNDED
As BeamSideInputLookupJoinRel
also matches this condition when both the inputs are
PCollection.IsBounded.BOUNDED
, to avoid conflicts, this rule is not matched when any of
the inputs to LogicalJoin
node are Seekable.
Modifier and Type | Field and Description |
---|---|
static BeamCoGBKJoinRule |
INSTANCE |
Modifier and Type | Method and Description |
---|---|
boolean |
matches(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptRuleCall call) |
void |
onMatch(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptRuleCall call) |
any, convert, convert, convertList, convertOperand, convertOperand, equals, equals, getOperand, getOperands, getOutConvention, getOutTrait, hashCode, none, operand, operand, operand, operand, operand, operandJ, operandJ, some, toString, unordered
public static final BeamCoGBKJoinRule INSTANCE
public boolean matches(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptRuleCall call)
matches
in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptRule
public void onMatch(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptRuleCall call)
onMatch
in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptRule