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:

java.io.Serializable, BeamSqlTable

Direct Known Subclasses:

BeamKafkaTable, BeamPCollectionTable, BigtableTable, MongoDbTable, TestTable, TextTable

public abstract class SchemaBaseBeamTable
extends BaseBeamTable
implements java.io.Serializable

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

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Schema	schema

Constructor Summary

Constructors

Constructor and Description
SchemaBaseBeamTable(Schema schema)

Method Summary

Modifier and Type	Method and 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 Detail

schema

protected Schema schema

Constructor Detail

SchemaBaseBeamTable

public SchemaBaseBeamTable(Schema schema)

Method Detail

getSchema

public Schema getSchema()

Description copied from interface: BeamSqlTable

Get the schema info of the table.

Specified by:

getSchema in interface BeamSqlTable