类 OceanBaseTable
- java.lang.Object
-
- org.apache.flink.cdc.connectors.oceanbase.catalog.OceanBaseTable
-
public class OceanBaseTable extends Object
Describe a OceanBase table.
-
-
嵌套类概要
嵌套类 修饰符和类型 类 说明 static classOceanBaseTable.BuilderBuild aOceanBaseTable.static classOceanBaseTable.TableTypeTypes of OceanBase table.
-
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 booleanequals(Object o)OceanBaseColumngetColumn(String columnName)List<OceanBaseColumn>getColumns()Optional<String>getComment()StringgetDatabaseName()Optional<List<String>>getPartitionKeys()Map<String,String>getProperties()Optional<List<String>>getTableKeys()StringgetTableName()OceanBaseTable.TableTypegetTableType()StringtoString()
-
-
-
方法详细资料
-
getDatabaseName
public String getDatabaseName()
-
getTableName
public String getTableName()
-
getTableType
public OceanBaseTable.TableType getTableType()
-
getColumns
public List<OceanBaseColumn> getColumns()
-
getColumn
public OceanBaseColumn getColumn(String columnName)
-
-