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.
BeamSqlTable	This interface defines a Beam Sql Table.
BeamSqlUdf	Interface to create a UDF in Beam SQL.

Class Summary

Class	Description
BeamSql	BeamSql is the DSL interface of BeamSQL.
BeamSqlCli	BeamSqlCli provides methods to execute Beam SQL with an interactive client.
QueryTransform	A PTransform representing an execution plan for a SQL query.
RowHelper	Atomic Coders for Row fields for SQL types.
RowHelper.BooleanCoder	Coder for Java type Boolean.
RowHelper.DateCoder	Coder for Java type Date, it's stored as Long.
RowHelper.DoubleCoder	Coder for Java type Double, it's stored as BigDecimal.
RowHelper.FloatCoder	Coder for Java type Float, it's stored as BigDecimal.
RowHelper.ShortCoder	Coder for Java type Short.
RowHelper.TimeCoder	Coder for Java type GregorianCalendar, it's stored as Long.
RowSqlType	Type builder for Row with SQL types.
RowSqlType.Builder	Builder class to construct RowType.
SqlRowTypeFactory	For internal use only; no backwards-compatibility guarantees.
SqlTypeCoder	Base class for coders for supported SQL types.
SqlTypeCoders	Coders for SQL types supported in Beam.

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

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