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

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

See: Description

Interface Summary

Interface	Description
BeamSqlSeekableTable	A seekable table converts a JOIN operator to an inline lookup.
BeamSqlUdf	Interface to create a UDF in Beam SQL.

Class Summary

Class	Description
BeamSqlCli	BeamSqlCli provides methods to execute Beam SQL with an interactive client.
SqlTransform	SqlTransform is the DSL interface of Beam SQL.
TableNameExtractionUtils	Helper class to extract table identifiers from the query.
TypedCombineFnDelegate<InputT,AccumT,OutputT>	A Combine.CombineFn delegating all relevant calls to given delegate.

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

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