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

Implementation classes of BeamSql.

See: Description

Class Summary

Class	Description
BeamCalciteSchema	Adapter from TableProvider to Schema.
BeamCalciteSchemaFactory	Factory that creates a BeamCalciteSchema.
BeamSqlEnv	BeamSqlEnv prepares the execution context for BeamSql and BeamSqlCli.
JdbcDriver	Calcite JDBC driver with Beam defaults.

Exception Summary

Exception	Description
ParseException	Exception thrown when Beam SQL is unable to parse the statement.

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

Implementation classes of BeamSql.