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
BeamRecordSqlType	Type provider for BeamRecord with SQL types.
BeamRecordSqlType.Builder	Builder class to construct BeamRecordSqlType.
BeamSql	BeamSql is the DSL interface of BeamSQL.
BeamSql.QueryTransform	A PTransform representing an execution plan for a SQL query.
BeamSql.SimpleQueryTransform	A PTransform representing an execution plan for a SQL query referencing a single table.
BeamSqlCli	BeamSqlCli provides methods to execute Beam SQL with an interactive client.
BeamSqlRecordHelper	A Coder encodes BeamRecord.
BeamSqlRecordHelper.BooleanCoder	Coder for Java type Boolean.
BeamSqlRecordHelper.DateCoder	Coder for Java type Date, it's stored as Long.
BeamSqlRecordHelper.DoubleCoder	Coder for Java type Double, it's stored as BigDecimal.
BeamSqlRecordHelper.FloatCoder	Coder for Java type Float, it's stored as BigDecimal.
BeamSqlRecordHelper.ShortCoder	Coder for Java type Short.
BeamSqlRecordHelper.TimeCoder	Coder for Java type GregorianCalendar, it's stored as Long.

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

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