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

Interface TableProvider

All Known Implementing Classes:

KafkaTableProvider, TextTableProvider

public interface TableProvider

A TableProvider handles the metadata CRUD of a specified kind of tables.

So there will be a provider to handle textfile(CSV) based tables, there is a provider to handle MySQL based tables, a provider to handle Casandra based tables etc.

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.

Method Detail

init

void init()

Init the provider.

getTableType

java.lang.String getTableType()

Gets the table type this provider handles.

createTable

void createTable(Table table)

Creates a table.

dropTable

void dropTable(java.lang.String tableName)

Drops a table.

Parameters:

tableName -

listTables

java.util.List<Table> listTables()

List all tables from this provider.

buildBeamSqlTable

BeamSqlTable buildBeamSqlTable(Table table)

Build a BeamSqlTable using the given table meta info.

close

void close()

Close the provider.