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

define table schema, to map with Beam IO components.

Class Summary

Class	Description
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.