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

Interface TableProvider

All Known Subinterfaces:

MetaStore

All Known Implementing Classes:

BigQueryTableProvider, InMemoryMetaStore, InMemoryMetaTableProvider, KafkaTableProvider, PubsubJsonTableProvider, ReadOnlyTableProvider, TestTableProvider, 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.

Note: all implementations marked with @AutoService(TableProvider.class) are automatically loaded by CLI or other cases when JdbcDriver is used with default connection parameters.

Method Summary

Modifier and Type	Method and Description
BeamSqlTable	buildBeamSqlTable(Table table) Build a BeamSqlTable using the given table meta info.
void	createTable(Table table) Creates a table.
void	dropTable(java.lang.String tableName) Drops a table.
java.util.Map<java.lang.String,Table>	getTables() Get all tables from this provider.
java.lang.String	getTableType() Gets the table type this provider handles.

Method Detail

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 -

getTables

java.util.Map<java.lang.String,Table> getTables()

Get all tables from this provider.

buildBeamSqlTable

BeamSqlTable buildBeamSqlTable(Table table)

Build a BeamSqlTable using the given table meta info.