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

Class DataCatalogTableProvider

java.lang.Object

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

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

All Implemented Interfaces:

CustomTableResolver, TableProvider

public class DataCatalogTableProvider
extends FullNameTableProvider

Uses DataCatalog to get the source type and schema for a table.

Method Summary

Modifier and Type	Method and Description
BeamSqlTable	buildBeamSqlTable(Table table) Build a BeamSqlTable using the given table meta info.
static DataCatalogTableProvider	create(DataCatalogPipelineOptions options)
void	createTable(Table table) Creates a table.
void	dropTable(java.lang.String tableName) Drops a table.
Table	getTable(java.lang.String tableNamePart) Get a specific table from this provider it is present, or null if it is not present.
Table	getTableByFullName(TableName fullTableName)
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.

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

getSubProvider, registerKnownTableNames

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.beam.sdk.extensions.sql.meta.provider.TableProvider

getSubProviders

Method Detail

create

public static DataCatalogTableProvider create(DataCatalogPipelineOptions options)

getTableType

public java.lang.String getTableType()

Description copied from interface: TableProvider

Gets the table type this provider handles.

createTable

public void createTable(Table table)

Description copied from interface: TableProvider

Creates a table.

dropTable

public void dropTable(java.lang.String tableName)

Description copied from interface: TableProvider

Drops a table.

getTables

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

Description copied from interface: TableProvider

Get all tables from this provider.

getTable

@Nullable
public Table getTable(java.lang.String tableNamePart)

Description copied from interface: TableProvider

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

getTableByFullName

@Nullable
public Table getTableByFullName(TableName fullTableName)

Specified by:

getTableByFullName in class FullNameTableProvider

buildBeamSqlTable

public BeamSqlTable buildBeamSqlTable(Table table)

Description copied from interface: TableProvider

Build a BeamSqlTable using the given table meta info.