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

Class BeamCalcSplittingRule

java.lang.Object

org.apache.beam.vendor.calcite.v1_20_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_20_0.org.apache.calcite.plan.RelOptRule

A RelOptRule that converts a LogicalCalc into a chain of AbstractBeamCalcRel nodes via CalcRelSplitter.

Field Summary

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

description, operands, relBuilderFactory

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BeamCalcSplittingRule(java.lang.String description)

Method Summary

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

Methods inherited from class org.apache.beam.vendor.calcite.v1_20_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 Detail

BeamCalcSplittingRule

protected BeamCalcSplittingRule(java.lang.String description)

Method Detail

matches

public boolean matches(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptRuleCall x)

Overrides:

matches in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptRule

onMatch

public void onMatch(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptRuleCall relOptRuleCall)

Specified by:

onMatch in class org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.plan.RelOptRule

getRelTypes

protected abstract CalcRelSplitter.RelType[] getRelTypes()