@DefaultAnnotation(value=edu.umd.cs.findbugs.annotations.NonNull.class)

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

RelOptRule to generate BeamRelNode.

See: Description

Interface Summary

Interface	Description
JoinRelOptRuleCall.JoinChecker	This is a function gets the output relation and checks if it is a legal relational node.

Class Summary

Class	Description
BeamAggregationRule	Rule to detect the window/trigger settings.
BeamBasicAggregationRule	Aggregation rule that doesn't include projection.
BeamCalcRule	A ConverterRule to replace Calc with BeamCalcRel.
BeamCoGBKJoinRule	Rule to convert LogicalJoin node to BeamCoGBKJoinRel node.
BeamEnumerableConverterRule	A ConverterRule to Convert BeamRelNode to EnumerableConvention.
BeamIntersectRule	ConverterRule to replace Intersect with BeamIntersectRel.
BeamIOPushDownRule
BeamIOSinkRule	A ConverterRule to replace TableModify with BeamIOSinkRel.
BeamJoinAssociateRule	This is very similar to JoinAssociateRule.
BeamJoinPushThroughJoinRule	This is exactly similar to JoinPushThroughJoinRule.
BeamMinusRule	ConverterRule to replace Minus with BeamMinusRel.
BeamSideInputJoinRule	Rule to convert LogicalJoin node to BeamSideInputJoinRel node.
BeamSideInputLookupJoinRule	Rule to convert LogicalJoin node to BeamSideInputLookupJoinRel node.
BeamSortRule	ConverterRule to replace Sort with BeamSortRel.
BeamUncollectRule	A ConverterRule to replace Uncollect with BeamUncollectRule.
BeamUnionRule	A ConverterRule to replace Union with BeamUnionRule.
BeamUnnestRule	A ConverterRule to replace Correlate Uncollect with BeamUnnestRule.
BeamValuesRule	ConverterRule to replace Values with BeamValuesRel.
JoinRelOptRuleCall	This is a class to catch the built join and check if it is a legal join before passing it to the actual RelOptRuleCall.

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

RelOptRule to generate BeamRelNode.