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 aBeamCalcRel
with aBeamCalcRel
.ARelOptRule
that converts aLogicalCalc
into a chain ofAbstractBeamCalcRel
nodes viaCalcRelSplitter
.Rule to convertLogicalJoin
node toBeamCoGBKJoinRel
node.ConverterRule
to replaceIntersect
withBeamIntersectRel
.This is very similar toJoinAssociateRule
.This is exactly similar toJoinPushThroughJoinRule
.ConverterRule
to replaceMatch
withBeamMatchRel
.ConverterRule
to replaceMinus
withBeamMinusRel
.Rule to convertLogicalJoin
node toBeamSideInputJoinRel
node.Rule to convertLogicalJoin
node toBeamSideInputLookupJoinRel
node.ConverterRule
to replaceSort
withBeamSortRel
.This is the conveter rule that converts a CalciteTableFunctionScan
to BeamTableFunctionScanRel
.ConverterRule
to replaceValues
withBeamValuesRel
.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.