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:

java.io.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(org.apache.beam.sdk.schemas.Schema schema, java.lang.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 Detail

TextJsonTable

public TextJsonTable(org.apache.beam.sdk.schemas.Schema schema,
                     java.lang.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)