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

Class BeamTextTable

java.lang.Object

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

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

All Implemented Interfaces:

java.io.Serializable, BeamSqlTable

Direct Known Subclasses:

BeamTextCSVTable

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

BeamTextTable represents a text file/directory(backed by TextIO).

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	filePattern

Fields inherited from class org.apache.beam.sdk.extensions.sql.impl.schema.BaseBeamTable

beamSqlRowType

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BeamTextTable(BeamRecordSqlType beamSqlRowType, java.lang.String filePattern)

Method Summary

Modifier and Type	Method and Description
BeamIOType	getSourceType() In Beam SQL, there's no difference between a batch query and a streaming query.

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

getRowType

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

Field Detail

filePattern

protected java.lang.String filePattern

Constructor Detail

BeamTextTable

protected BeamTextTable(BeamRecordSqlType beamSqlRowType,
                        java.lang.String filePattern)

Method Detail

getSourceType

public BeamIOType getSourceType()

Description copied from interface: BeamSqlTable

In Beam SQL, there's no difference between a batch query and a streaming query. BeamIOType is used to validate the sources.

Specified by:

getSourceType in interface BeamSqlTable