程序包的使用
org.apache.flink.cdc.connectors.oceanbase.catalog
-
使用org.apache.flink.cdc.connectors.oceanbase.catalog的程序包 程序包 说明 org.apache.flink.cdc.connectors.oceanbase.catalog org.apache.flink.cdc.connectors.oceanbase.sink -
org.apache.flink.cdc.connectors.oceanbase.catalog使用的org.apache.flink.cdc.connectors.oceanbase.catalog中的类 类 说明 OceanBaseCatalog AOceanBaseCatalogfor OceanBase connector that supports schema evolution.OceanBaseCatalogException A catalog-related, runtime exception.OceanBaseColumn Describe a column of OceanBase table.OceanBaseColumn.Builder Build aOceanBaseColumn.OceanBaseTable Describe a OceanBase table.OceanBaseTable.Builder Build aOceanBaseTable.OceanBaseTable.TableType Types of OceanBase table. -
org.apache.flink.cdc.connectors.oceanbase.sink使用的org.apache.flink.cdc.connectors.oceanbase.catalog中的类 类 说明 OceanBaseColumn.Builder Build aOceanBaseColumn.OceanBaseTable Describe a OceanBase table.