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

package org.apache.beam.sdk.extensions.sql.impl.rel

BeamSQL specified nodes, to replace RelNode.

Related Packages

Package	Description
org.apache.beam.sdk.extensions.sql.impl	Implementation classes of BeamSql.

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.
BeamLogicalConvention	Convention for Beam SQL.
BeamMatchRel	BeamRelNode to replace a Match node.
BeamMinusRel	BeamRelNode to replace a Minus node.
BeamPushDownIOSourceRel
BeamRelNode	A RelNode that can also give a PTransform that implements the expression.
BeamSetOperatorRelBase	Delegate for Set operators: BeamUnionRel, BeamIntersectRel and BeamMinusRel.
BeamSetOperatorRelBase.OpType	Set operator type.
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.