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

define table schema, to map with Beam IO components.

See: Description

Interface Summary

Interface	Description
BeamSqlTable	This interface defines a Beam Sql Table.

Class Summary

Class	Description
BaseBeamTable	Each IO in Beam has one table schema, by extending BaseBeamTable.
BeamPCollectionTable	BeamPCollectionTable converts a PCollection<BeamSqlRow> as a virtual table, then a downstream query can query directly.
BeamTableUtils	Utility methods for working with BeamTable.

Enum Summary

Enum	Description
BeamIOType	Type as a source IO, determined whether it's a STREAMING process, or batch process.

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

define table schema, to map with Beam IO components.