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

Interface TableProvider

All Known Subinterfaces:

CustomTableResolver, MetaStore

All Known Implementing Classes:

AvroTableProvider, BigQueryTableProvider, DataCatalogTableProvider, DataStoreV1TableProvider, FullNameTableProvider, GenerateSequenceTableProvider, InMemoryMetaStore, InMemoryMetaTableProvider, KafkaTableProvider, MongoDbTableProvider, ParquetTableProvider, 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.
default TableProvider	getSubProvider(java.lang.String name) Returns a sub-provider, e.g.
default java.util.Set<java.lang.String>	getSubProviders() Returns all sub-providers, e.g.
default Table	getTable(java.lang.String tableName) Get a specific table from this provider it is present, or null if it is not present.
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.

getTable

@Nullable
default Table getTable(java.lang.String tableName)

Get a specific table from this provider it is present, or null if it is not present.

buildBeamSqlTable

BeamSqlTable buildBeamSqlTable(Table table)

Build a BeamSqlTable using the given table meta info.

getSubProviders

default java.util.Set<java.lang.String> getSubProviders()

Returns all sub-providers, e.g. sub-schemas. Temporary, this logic needs to live in BeamCalciteSchema.

getSubProvider

default TableProvider getSubProvider(java.lang.String name)

Returns a sub-provider, e.g. sub-schema. Temporary, this logic needs to live in BeamCalciteSchema.