Package org.apache.beam.sdk.extensions.sql.meta

Class SchemaBaseBeamTable

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.BaseBeamTable

org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable

All Implemented Interfaces:

Serializable, BeamSqlTable

Direct Known Subclasses:

BeamKafkaTable, BeamPCollectionTable, BigtableTable, DataGeneratorTable, MongoDbTable, TestTable, TextTable

public abstract class SchemaBaseBeamTable
extends BaseBeamTable
implements Serializable

Each IO in Beam has one table schema, by extending SchemaBaseBeamTable.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected Schema	schema

Constructor Summary

Constructors

Constructor	Description
SchemaBaseBeamTable(Schema schema)

Method Summary

Modifier and Type	Method	Description
Schema	getSchema()	Get the schema info of the table.

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.BaseBeamTable

buildIOReader, constructFilter, getTableStatistics, supportsProjects

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.beam.sdk.extensions.sql.meta.BeamSqlTable

buildIOReader, buildIOWriter, isBounded

Field Details

schema

protected Schema schema

Constructor Details

SchemaBaseBeamTable

public SchemaBaseBeamTable(Schema schema)

Method Details

getSchema

public Schema getSchema()

Description copied from interface: BeamSqlTable

Get the schema info of the table.

Specified by:

getSchema in interface BeamSqlTable