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

Class TextJsonTable

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.BaseBeamTable

org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable

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

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

All Implemented Interfaces:

Serializable, BeamSqlTable

@Internal
public class TextJsonTable
extends TextTable

TextJsonTable is a BeamSqlTable that reads text files and converts them according to the JSON format.

Support format is "json".

Check ObjectMapper javadoc for more info on reading and writing JSON.

See Also:

• Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable

schema

Constructor Summary

Constructors

Constructor	Description
TextJsonTable(Schema schema, String filePattern, org.apache.beam.sdk.extensions.sql.meta.provider.text.TextTableProvider.JsonToRow readConverter, org.apache.beam.sdk.extensions.sql.meta.provider.text.TextTableProvider.RowToJson writerConverter)

Method Summary

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.provider.text.TextTable

buildIOReader, buildIOWriter, getFilePattern, getTableStatistics, isBounded

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable

getSchema

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

buildIOReader, constructFilter, supportsProjects

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TextJsonTable

public TextJsonTable(Schema schema,
 String filePattern,
 org.apache.beam.sdk.extensions.sql.meta.provider.text.TextTableProvider.JsonToRow readConverter,
 org.apache.beam.sdk.extensions.sql.meta.provider.text.TextTableProvider.RowToJson writerConverter)