org.apache.beam.sdk.extensions.sql.meta.provider.text

Class BeamTextTable

java.lang.Object

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

org.apache.beam.sdk.extensions.sql.meta.provider.text.BeamTextTable

All Implemented Interfaces:

java.io.Serializable, BeamSqlTable

Direct Known Subclasses:

BeamTextCSVTable

public abstract class BeamTextTable
extends BaseBeamTable

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

schema

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BeamTextTable(Schema schema, 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

getSchema

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

Field Detail

filePattern

protected java.lang.String filePattern

Constructor Detail

BeamTextTable

protected BeamTextTable(Schema schema,
                        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.