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, BeamTextTable

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 BeamRecordSqlType	beamSqlRowType

Constructor Summary

Constructors

Constructor and Description
BaseBeamTable(BeamRecordSqlType beamSqlRowType)

Method Summary

Modifier and Type	Method and Description
BeamRecordSqlType	getRowType() 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.impl.schema.BeamSqlTable

buildIOReader, buildIOWriter, getSourceType

Field Detail

beamSqlRowType

protected BeamRecordSqlType beamSqlRowType

Constructor Detail

BaseBeamTable

public BaseBeamTable(BeamRecordSqlType beamSqlRowType)

Method Detail

getRowType

public BeamRecordSqlType getRowType()

Description copied from interface: BeamSqlTable

Get the schema info of the table.

Specified by:

getRowType in interface BeamSqlTable