Package org.apache.beam.sdk.extensions.sql.impl.rule

Class BeamCoGBKJoinRule

  • public class BeamCoGBKJoinRule
extends org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptRule
    Rule to convert 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.

    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptRule

        org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptRule.ConverterRelOptRuleOperand

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static BeamCoGBKJoinRule INSTANCE  

      • Fields inherited from class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptRule

        description, operands, relBuilderFactory

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean matches​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptRuleCall call)  
      void onMatch​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptRuleCall call)  

      • Methods inherited from class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptRule

        any, convert, convert, convert, convert, convertList, convertOperand, convertOperand, equals, equals, getOperand, getOperands, getOutConvention, getOutTrait, hashCode, none, operand, operand, operand, operand, operand, operandJ, operandJ, some, toString, unordered

      • Methods inherited from class java.lang.Object

        clone, finalize, getClass, notify, notifyAll, wait, wait, wait

    • Method Detail

      • matches

        public boolean matches​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptRuleCall call)
        Overrides:
        matches in class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptRule

      • onMatch

        public void onMatch​(org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptRuleCall call)
        Specified by:
        onMatch in class org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptRule