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

Class IcebergTableProvider

java.lang.Object

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

All Implemented Interfaces:

TableProvider

public class IcebergTableProvider
extends java.lang.Object
implements TableProvider

A table provider for Iceberg tables. CREATE and DROP operations are performed on real external tables.

Constructor Summary

Constructors

Constructor and Description
IcebergTableProvider(java.lang.String name, java.util.Map<java.lang.String,java.lang.String> properties)

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.
boolean	supportsPartitioning(Table table)

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, getTable

Constructor Detail

IcebergTableProvider

public IcebergTableProvider(java.lang.String name,
                            java.util.Map<java.lang.String,java.lang.String> properties)

Method Detail

getTableType

public java.lang.String getTableType()

Description copied from interface: TableProvider

Gets the table type this provider handles.

Specified by:

getTableType in interface TableProvider

createTable

public void createTable(Table table)

Description copied from interface: TableProvider

Creates a table.

Specified by:

createTable in interface TableProvider

dropTable

public void dropTable(java.lang.String tableName)

Description copied from interface: TableProvider

Drops a table.

Specified by:

dropTable in interface TableProvider

getTables

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

Description copied from interface: TableProvider

Get all tables from this provider.

Specified by:

getTables in interface TableProvider

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

supportsPartitioning

public boolean supportsPartitioning(Table table)

Specified by:

supportsPartitioning in interface TableProvider