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

Class BaseBeamTable

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, BeamSqlTable

Direct Known Subclasses:

BeamKafkaTable, BeamPCollectionTable, ParquetTable, TestTable, TextTable

public abstract class BaseBeamTable
extends java.lang.Object
implements BeamSqlTable, java.io.Serializable

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

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Schema	schema

Constructor Summary

Constructors

Constructor and Description
BaseBeamTable(Schema schema)

Method Summary

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

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.BeamSqlTable

buildIOReader, buildIOWriter, getRowCount, isBounded

Field Detail

schema

protected Schema schema

Constructor Detail

BaseBeamTable

public BaseBeamTable(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