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

define table schema, to map with Beam IO components.

See: Description

Class Summary

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

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

define table schema, to map with Beam IO components.