public class IcebergTableProvider extends java.lang.Object implements TableProvider
Constructor and Description |
---|
IcebergTableProvider(java.lang.String name,
java.util.Map<java.lang.String,java.lang.String> properties) |
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) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getSubProvider, getSubProviders, getTable
public IcebergTableProvider(java.lang.String name, java.util.Map<java.lang.String,java.lang.String> properties)
public java.lang.String getTableType()
TableProvider
getTableType
in interface TableProvider
public void createTable(Table table)
TableProvider
createTable
in interface TableProvider
public void dropTable(java.lang.String tableName)
TableProvider
dropTable
in interface TableProvider
public java.util.Map<java.lang.String,Table> getTables()
TableProvider
getTables
in interface TableProvider
public BeamSqlTable buildBeamSqlTable(Table table)
TableProvider
BeamSqlTable
using the given table meta info.buildBeamSqlTable
in interface TableProvider
public boolean supportsPartitioning(Table table)
supportsPartitioning
in interface TableProvider