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

Class TextTableProvider

java.lang.Object

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

All Implemented Interfaces:

TableProvider

public class TextTableProvider
extends java.lang.Object
implements TableProvider

Text table provider.

A sample of text table is:

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

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.
void	close() Close the provider.
void	createTable(Table table) Creates a table.
void	dropTable(java.lang.String tableName) Drops a table.
java.lang.String	getTableType() Gets the table type this provider handles.
void	init() Init the provider.
java.util.List<Table>	listTables() List all tables from this provider.

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.

Specified by:

getTableType in interface TableProvider

buildBeamSqlTable

public BeamSqlTable buildBeamSqlTable(Table table)

Description copied from interface: TableProvider

Build a BeamSqlTable using the given table meta info.

Specified by:

buildBeamSqlTable in interface TableProvider

createTable

public void createTable(Table table)

Description copied from interface: TableProvider

Creates a table.

Specified by:

createTable in interface TableProvider

dropTable

public void dropTable(java.lang.String tableName)

Description copied from interface: TableProvider

Drops a table.

Specified by:

dropTable in interface TableProvider

listTables

public java.util.List<Table> listTables()

Description copied from interface: TableProvider

List all tables from this provider.

Specified by:

listTables in interface TableProvider

init

public void init()

Description copied from interface: TableProvider

Init the provider.

Specified by:

init in interface TableProvider

close

public void close()

Description copied from interface: TableProvider

Close the provider.

Specified by:

close in interface TableProvider