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

Class IcebergMetastore

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore

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

All Implemented Interfaces:

TableProvider, MetaStore

public class IcebergMetastore
extends InMemoryMetaStore

Constructor Summary

Constructors

Constructor	Description
IcebergMetastore(String db, IcebergCatalogConfig catalogConfig)

Method Summary

Modifier and Type	Method	Description
BeamSqlTable	buildBeamSqlTable(Table table)	Build a BeamSqlTable using the given table meta info.
void	createTable(Table table)	Creates a table.
void	dropTable(String tableName)	Drops a table.
@Nullable Table	getTable(String name)	Get a specific table from this provider it is present, or null if it is not present.
Map<String,Table>	getTables()	Get all tables from this provider.
String	getTableType()	Gets the table type this provider handles.
void	registerProvider(TableProvider provider)	Register a table provider.
boolean	supportsPartitioning(Table table)

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.store.InMemoryMetaStore

getProvider, tableProviders, validateTableType

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

getSubProvider, getSubProviders

Constructor Details

IcebergMetastore

public IcebergMetastore(String db,
 IcebergCatalogConfig catalogConfig)

Method Details

getTableType

public String getTableType()

Description copied from interface: TableProvider

Gets the table type this provider handles.

Specified by:

getTableType in interface TableProvider

Overrides:

getTableType in class InMemoryMetaStore

createTable

public void createTable(Table table)

Description copied from interface: TableProvider

Creates a table.

Specified by:

createTable in interface TableProvider

Overrides:

createTable in class InMemoryMetaStore

dropTable

public void dropTable(String tableName)

Description copied from interface: TableProvider

Drops a table.

Specified by:

dropTable in interface TableProvider

Overrides:

dropTable in class InMemoryMetaStore

Parameters:

tableName -

getTables

public Map<String,Table> getTables()

Description copied from interface: TableProvider

Get all tables from this provider.

Specified by:

getTables in interface TableProvider

Overrides:

getTables in class InMemoryMetaStore

getTable

public @Nullable Table getTable(String name)

Description copied from interface: TableProvider

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

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

Overrides:

buildBeamSqlTable in class InMemoryMetaStore

supportsPartitioning

public boolean supportsPartitioning(Table table)

Specified by:

supportsPartitioning in interface TableProvider

Overrides:

supportsPartitioning in class InMemoryMetaStore

registerProvider

public void registerProvider(TableProvider provider)

Description copied from interface: MetaStore

Register a table provider.

Specified by:

registerProvider in interface MetaStore

Overrides:

registerProvider in class InMemoryMetaStore

Parameters:

provider -