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 RowType	rowType

Constructor Summary

Constructors

Constructor and Description
BaseBeamTable(RowType rowType)

Method Summary

Modifier and Type	Method and Description
RowType	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.BeamSqlTable

buildIOReader, buildIOWriter, getSourceType

Field Detail

rowType

protected RowType rowType

Constructor Detail

BaseBeamTable

public BaseBeamTable(RowType rowType)

Method Detail

getRowType

public RowType getRowType()

Description copied from interface: BeamSqlTable

Get the schema info of the table.

Specified by:

getRowType in interface BeamSqlTable