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

使用OceanBaseColumn的程序包

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

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

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

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

返回变量类型为OceanBaseColumn的类型的org.apache.flink.cdc.connectors.oceanbase.catalog中的方法

修饰符和类型	方法	说明
List<OceanBaseColumn>	OceanBaseTable.getColumns()

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

修饰符和类型	方法	说明
protected String	OceanBaseMySQLCatalog.buildColumnStmt(OceanBaseColumn column)

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

修饰符和类型	方法	说明
abstract void	OceanBaseCatalog.alterAddColumns(String databaseName, String tableName, List<OceanBaseColumn> addColumns)
void	OceanBaseMySQLCatalog.alterAddColumns(String databaseName, String tableName, List<OceanBaseColumn> addColumns)
void	OceanBaseOracleCatalog.alterAddColumns(String databaseName, String tableName, List<OceanBaseColumn> addColumns)
protected String	OceanBaseMySQLCatalog.buildAlterAddColumnsSql(String databaseName, String tableName, List<OceanBaseColumn> addColumns)
OceanBaseTable.Builder	OceanBaseTable.Builder.setColumns(List<OceanBaseColumn> columns)