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

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

BeamSQL provides a new interface to run a SQL statement with Beam.

Related Packages

Package	Description
org.apache.beam.sdk.extensions.sql.example	Example how to use Data Catalog table provider.
org.apache.beam.sdk.extensions.sql.expansion	External Transform Registration for Beam SQL.
org.apache.beam.sdk.extensions.sql.impl	Implementation classes of BeamSql.
org.apache.beam.sdk.extensions.sql.meta	Metadata related classes.
org.apache.beam.sdk.extensions.sql.provider	Package containing UDF providers for testing.
org.apache.beam.sdk.extensions.sql.udf	Provides interfaces for defining user-defined functions in Beam SQL.
org.apache.beam.sdk.extensions.sql.zetasql	Deprecated. Use Calcite SQL dialect.

Class	Description
BeamSqlCli	BeamSqlCli provides methods to execute Beam SQL with an interactive client.
BeamSqlSeekableTable	A seekable table converts a JOIN operator to an inline lookup.
BeamSqlUdf	Interface to create a UDF in Beam SQL.
SqlTransform	SqlTransform is the DSL interface of Beam SQL.
TableNameExtractionUtils	Helper class to extract table identifiers from the query.
TableUtils
TypedCombineFnDelegate<InputT,AccumT,OutputT>	A Combine.CombineFn delegating all relevant calls to given delegate.