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

Class BeamSideInputJoinRule

  • public class BeamSideInputJoinRule
extends org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.plan.RelOptRule
    Rule to convert LogicalJoin node to BeamSideInputJoinRel node.

    This rule is matched when one of the input to LogicalJoin node is PCollection.IsBounded.BOUNDED and the other node is PCollection.IsBounded.UNBOUNDED

    As BeamSideInputLookupJoinRel also matches this condition, 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 BeamSideInputJoinRule 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