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

Class BeamCalcSplittingRule

java.lang.Object
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptRule
org.apache.beam.sdk.extensions.sql.impl.rule.BeamCalcSplittingRule
Direct Known Subclasses:
BeamJavaUdfCalcRule, BeamZetaSqlCalcRule, BeamZetaSqlCalcSplittingRule
public abstract class BeamCalcSplittingRule extends org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptRule
A RelOptRule that converts a LogicalCalc into a chain of AbstractBeamCalcRel nodes via CalcRelSplitter.

  • Nested Class Summary

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

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

  • Field Summary

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

    description, operands, relBuilderFactory

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    protected
    BeamCalcSplittingRule(String description)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected abstract CalcRelSplitter.RelType[]
    getRelTypes()
     
    boolean
    matches(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptRuleCall x)
     
    void
    onMatch(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptRuleCall relOptRuleCall)
     

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

    any, 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

  • Constructor Details

    • BeamCalcSplittingRule

      protected BeamCalcSplittingRule(String description)

  • Method Details

    • matches

      public boolean matches(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptRuleCall x)
      Overrides:
      matches in class org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptRule

    • onMatch

      public void onMatch(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptRuleCall relOptRuleCall)
      Specified by:
      onMatch in class org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.plan.RelOptRule

    • getRelTypes

      protected abstract CalcRelSplitter.RelType[] getRelTypes()