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

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

define table schema, to map with Beam IO components.

Related Packages

Package	Description
org.apache.beam.sdk.extensions.sql.impl	Implementation classes of BeamSql.

Classes

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.