org.apache.beam.sdk.extensions.sql.impl.rel (Apache Beam 2.59.0)

Interface Summary
Interface Description

BeamRelNode
A RelNode that can also give a PTransform that implements the expression.

Interface Summary
Interface	Description
BeamRelNode	A `RelNode` that can also give a `PTransform` that implements the expression.

Class Summary
Class	Description
AbstractBeamCalcRel	BeamRelNode to replace `Project` and `Filter` node.
BeamAggregationRel	`BeamRelNode` to replace a `Aggregate` node.
BeamCalcRel	BeamRelNode to replace `Project` and `Filter` node.
BeamCalcRel.WrappedList<T>	WrappedList translates `List` on access.
BeamCalcRel.WrappedMap<V>	WrappedMap translates `Map` on access.
BeamCalcRel.WrappedRow	WrappedRow translates `Row` on access.
BeamCoGBKJoinRel	A `BeamJoinRel` which does CoGBK Join
BeamEnumerableConverter	BeamRelNode to replace a `Enumerable` node.
BeamIntersectRel	`BeamRelNode` to replace a `Intersect` node.
BeamIOSinkRel	BeamRelNode to replace a `TableModify` node.
BeamIOSourceRel	BeamRelNode to replace a `TableScan` node.
BeamJoinRel	An abstract `BeamRelNode` to implement Join Rels.
BeamMatchRel	`BeamRelNode` to replace a `Match` node.
BeamMinusRel	`BeamRelNode` to replace a `Minus` node.
BeamPushDownIOSourceRel
BeamSetOperatorRelBase	Delegate for Set operators: `BeamUnionRel`, `BeamIntersectRel` and `BeamMinusRel`.
BeamSideInputJoinRel	A `BeamJoinRel` which does sideinput Join
BeamSideInputLookupJoinRel	A `BeamJoinRel` which does Lookup Join
BeamSortRel	`BeamRelNode` to replace a `Sort` node.
BeamSortRel.BeamSqlRowComparator
BeamSqlRelUtils	Utilities for `BeamRelNode`.
BeamTableFunctionScanRel	BeamRelNode to replace `TableFunctionScan`.
BeamUncollectRel	`BeamRelNode` to implement an uncorrelated `Uncollect`, aka UNNEST.
BeamUnionRel	`BeamRelNode` to replace a `Union`.
BeamUnnestRel	`BeamRelNode` to implement UNNEST, supporting specifically only `Correlate` with `Uncollect`.
BeamValuesRel	`BeamRelNode` to replace a `Values` node.
BeamWindowRel	`BeamRelNode` to replace a `Window` node.
CalcRelSplitter	CalcRelSplitter operates on a `Calc` with multiple `RexCall` sub-expressions that cannot all be implemented by a single concrete `RelNode`.
CalcRelSplitter.RelType	Type of relational expression.

Enum Summary
Enum Description

BeamLogicalConvention
Convention for Beam SQL.

BeamSetOperatorRelBase.OpType
Set operator type.

Enum Summary
Enum	Description
BeamLogicalConvention	Convention for Beam SQL.
BeamSetOperatorRelBase.OpType	Set operator type.

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

BeamSQL specified nodes, to replace RelNode.