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

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.

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.