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
BeamSqlUdf	Interface to create a UDF in Beam SQL.

Class Summary

Class	Description
BeamRecordSqlType	Type provider for BeamRecord with SQL types.
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.
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.