@Experimental

Package org.apache.beam.sdk.extensions.sql.zetasql

ZetaSQL Dialect package.

See: Description

Class Summary

Class	Description
BeamJavaUdfCalcRule	A BeamCalcSplittingRule to replace Calc with BeamCalcRel.
BeamZetaSqlCalcMergeRule	Planner rule to merge a BeamZetaSqlCalcRel with a BeamZetaSqlCalcRel.
BeamZetaSqlCalcRel	BeamRelNode to replace Project and Filter node based on the ZetaSQL expression evaluator.
BeamZetaSqlCalcRule	A BeamCalcSplittingRule to replace Calc with BeamZetaSqlCalcRel.
BeamZetaSqlCalcSplittingRule	A BeamCalcSplittingRule that converts a LogicalCalc to a chain of BeamZetaSqlCalcRel and/or BeamCalcRel via CalcRelSplitter.
BeamZetaSqlCatalog	Catalog for registering tables and functions.
DateTimeUtils	DateTimeUtils.
QueryTrait	QueryTrait.
SqlAnalyzer	Adapter for Analyzer to simplify the API for parsing the query and resolving the AST.
TableResolution	Utility methods to resolve a table, given a top-level Calcite schema and a table path.
ZetaSqlBeamTranslationUtils	Utility methods for ZetaSQL <=> Beam translation.
ZetaSqlCalciteTranslationUtils	Utility methods for ZetaSQL <=> Calcite translation.
ZetaSQLQueryPlanner	ZetaSQLQueryPlanner.

Exception Summary

Exception	Description
ZetaSqlException	Exception to be thrown by the Beam ZetaSQL planner.

Package org.apache.beam.sdk.extensions.sql.zetasql Description

ZetaSQL Dialect package.