public class DataCatalogTableProvider extends FullNameTableProvider implements java.lang.AutoCloseable
Modifier and Type | Method and Description |
---|---|
BeamSqlTable |
buildBeamSqlTable(Table table)
Build a
BeamSqlTable using the given table meta info. |
void |
close() |
static DataCatalogTableProvider |
create(DataCatalogPipelineOptions options) |
static com.google.cloud.datacatalog.v1beta1.DataCatalogClient |
createDataCatalogClient(DataCatalogPipelineOptions options) |
void |
createTable(Table table)
Creates a table.
|
void |
dropTable(java.lang.String tableName)
Drops a table.
|
@Nullable Table |
getTable(java.lang.String tableName)
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.
|
boolean |
setSchemaIfNotPresent(java.lang.String resource,
Schema schema) |
getSubProvider, registerKnownTableNames
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getSubProviders
public static DataCatalogTableProvider create(DataCatalogPipelineOptions options)
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 @Nullable Table getTable(java.lang.String tableName)
TableProvider
getTable
in interface TableProvider
public Table getTableByFullName(TableName fullTableName)
getTableByFullName
in class FullNameTableProvider
public BeamSqlTable buildBeamSqlTable(Table table)
TableProvider
BeamSqlTable
using the given table meta info.buildBeamSqlTable
in interface TableProvider
@Internal public static com.google.cloud.datacatalog.v1beta1.DataCatalogClient createDataCatalogClient(DataCatalogPipelineOptions options)
@Internal public boolean setSchemaIfNotPresent(java.lang.String resource, Schema schema)
public void close()
close
in interface java.lang.AutoCloseable