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

Class TextTableProvider

java.lang.Object

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

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

All Implemented Interfaces:

TableProvider

@AutoService(value=TableProvider.class)
public class TextTableProvider
extends InMemoryMetaTableProvider

Text table provider.

A sample of text table is:

 CREATE TABLE ORDERS(
   ID INT COMMENT 'this is the primary key',
   NAME VARCHAR(127) COMMENT 'this is the name'
 )
 TYPE 'text'
 COMMENT 'this is the table orders'
 LOCATION '/home/admin/orders'
 TBLPROPERTIES '{"format":"csv", "csvformat": "Excel"}' -- format of each text line(csv format)
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TextTableProvider.CsvToRow Read-side converter for TextTable with format 'csv'.
static class	TextTableProvider.LinesReadConverter Read-side converter for TextTable with format 'lines'.
static class	TextTableProvider.LinesWriteConverter Write-side converter for for TextTable with format 'lines'.

Constructor Summary

Constructors

Constructor and Description
TextTableProvider()

Method Summary

Modifier and Type	Method and Description
BeamSqlTable	buildBeamSqlTable(Table table) Build a BeamSqlTable using the given table meta info.
java.lang.String	getTableType() Gets the table type this provider handles.

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

createTable, dropTable, getTables

Methods inherited from class java.lang.Object

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

Constructor Detail

TextTableProvider

public TextTableProvider()

Method Detail

getTableType

public java.lang.String getTableType()

Description copied from interface: TableProvider

Gets the table type this provider handles.

buildBeamSqlTable

public BeamSqlTable buildBeamSqlTable(Table table)

Description copied from interface: TableProvider

Build a BeamSqlTable using the given table meta info.