类的使用
org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable

使用OceanBaseTable的程序包

程序包	说明
org.apache.flink.cdc.connectors.oceanbase.catalog
org.apache.flink.cdc.connectors.oceanbase.sink

org.apache.flink.cdc.connectors.oceanbase.catalog中OceanBaseTable的使用

返回OceanBaseTable的org.apache.flink.cdc.connectors.oceanbase.catalog中的方法

修饰符和类型	方法	说明
OceanBaseTable	OceanBaseTable.Builder.build()

参数类型为OceanBaseTable的org.apache.flink.cdc.connectors.oceanbase.catalog中的方法

修饰符和类型	方法	说明
protected String	OceanBaseMySQLCatalog.buildCreateTableSql(OceanBaseTable table, boolean ignoreIfExists)
abstract void	OceanBaseCatalog.createTable(OceanBaseTable table, boolean ignoreIfExists)
void	OceanBaseMySQLCatalog.createTable(OceanBaseTable table, boolean ignoreIfExists)	Creates a table.
void	OceanBaseOracleCatalog.createTable(OceanBaseTable table, boolean ignoreIfExists)

org.apache.flink.cdc.connectors.oceanbase.sink中OceanBaseTable的使用

返回OceanBaseTable的org.apache.flink.cdc.connectors.oceanbase.sink中的方法

修饰符和类型	方法	说明
static OceanBaseTable	OceanBaseUtils.toOceanBaseTable(org.apache.flink.cdc.common.event.TableId tableId, org.apache.flink.cdc.common.schema.Schema schema)	Convert a source table to OceanBaseTable.