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
Project
andFilter
node.BeamRelNode
to replace aAggregate
node.BeamRelNode to replaceProject
andFilter
node.WrappedList translatesList
on access.WrappedMap translatesMap
on access.WrappedRow translatesRow
on access.ABeamJoinRel
which does CoGBK JoinBeamRelNode to replace aEnumerable
node.BeamRelNode
to replace aIntersect
node.BeamRelNode to replace aTableModify
node.BeamRelNode to replace aTableScan
node.An abstractBeamRelNode
to implement Join Rels.Convention for Beam SQL.BeamRelNode
to replace aMatch
node.BeamRelNode
to replace aMinus
node.ARelNode
that can also give aPTransform
that implements the expression.Delegate for Set operators:BeamUnionRel
,BeamIntersectRel
andBeamMinusRel
.Set operator type.ABeamJoinRel
which does sideinput JoinABeamJoinRel
which does Lookup JoinBeamRelNode
to replace aSort
node.Utilities forBeamRelNode
.BeamRelNode to replaceTableFunctionScan
.BeamRelNode
to implement an uncorrelatedUncollect
, aka UNNEST.BeamRelNode
to replace aUnion
.BeamRelNode
to replace aValues
node.BeamRelNode
to replace aWindow
node.CalcRelSplitter operates on aCalc
with multipleRexCall
sub-expressions that cannot all be implemented by a single concreteRelNode
.Type of relational expression.