Package org.apache.beam.sdk.extensions.sql.impl.rule
@DefaultAnnotation(org.checkerframework.checker.nullness.qual.NonNull.class)
package org.apache.beam.sdk.extensions.sql.impl.rule
RelOptRule to generate
BeamRelNode.-
ClassDescriptionThis rule is essentially a wrapper around Calcite's
AggregateProjectMergeRule.Rule to detect the window/trigger settings.Aggregation rule that doesn't include projection.Planner rule to merge aBeamCalcRelwith aBeamCalcRel.ARelOptRulethat converts aLogicalCalcinto a chain ofAbstractBeamCalcRelnodes viaCalcRelSplitter.Rule to convertLogicalJoinnode toBeamCoGBKJoinRelnode.ConverterRuleto replaceIntersectwithBeamIntersectRel.This is very similar toJoinAssociateRule.This is exactly similar toJoinPushThroughJoinRule.ConverterRuleto replaceMatchwithBeamMatchRel.ConverterRuleto replaceMinuswithBeamMinusRel.Rule to convertLogicalJoinnode toBeamSideInputJoinRelnode.Rule to convertLogicalJoinnode toBeamSideInputLookupJoinRelnode.ConverterRuleto replaceSortwithBeamSortRel.This is the conveter rule that converts a CalciteTableFunctionScanto BeamTableFunctionScanRel.ConverterRuleto replaceValueswithBeamValuesRel.This is a class to catch the built join and check if it is a legal join before passing it to the actual RelOptRuleCall.This is a function gets the output relation and checks if it is a legal relational node.