Package org.apache.beam.sdk.extensions.sql.impl.rel
@DefaultAnnotation(org.checkerframework.checker.nullness.qual.NonNull.class)
package org.apache.beam.sdk.extensions.sql.impl.rel
BeamSQL specified nodes, to replace
RelNode.-
ClassDescriptionBeamRelNode to replace
ProjectandFilternode.BeamRelNodeto replace aAggregatenode.BeamRelNode to replaceProjectandFilternode.WrappedList translatesListon access.WrappedMap translatesMapon access.WrappedRow translatesRowon access.ABeamJoinRelwhich does CoGBK JoinBeamRelNode to replace aEnumerablenode.BeamRelNodeto replace aIntersectnode.BeamRelNode to replace aTableModifynode.BeamRelNode to replace aTableScannode.An abstractBeamRelNodeto implement Join Rels.Convention for Beam SQL.BeamRelNodeto replace aMatchnode.BeamRelNodeto replace aMinusnode.ARelNodethat can also give aPTransformthat implements the expression.Delegate for Set operators:BeamUnionRel,BeamIntersectRelandBeamMinusRel.Set operator type.ABeamJoinRelwhich does sideinput JoinABeamJoinRelwhich does Lookup JoinBeamRelNodeto replace aSortnode.Utilities forBeamRelNode.BeamRelNode to replaceTableFunctionScan.BeamRelNodeto implement an uncorrelatedUncollect, aka UNNEST.BeamRelNodeto replace aUnion.BeamRelNodeto replace aValuesnode.BeamRelNodeto replace aWindownode.CalcRelSplitter operates on aCalcwith multipleRexCallsub-expressions that cannot all be implemented by a single concreteRelNode.Type of relational expression.