org.apache.paimon.flink.action.cdc.schema

Interface JdbcTableInfo

All Known Implementing Classes:

AllMergedJdbcTableInfo, ShardsMergedJdbcTableInfo, UnmergedJdbcTableInfo

public interface JdbcTableInfo

Describe a MySQL table.

Method Summary

Modifier and Type	Method and Description
List<Identifier>	identifiers() Return all MySQL table identifiers that build this schema.
String	location() To indicate where is the table from.
Schema	schema()
String	tableName()
String	toPaimonTableName() Convert to corresponding Paimon table name.

Method Detail

location

String location()

To indicate where is the table from.

identifiers

List<Identifier> identifiers()

Return all MySQL table identifiers that build this schema.

tableName

String tableName()

toPaimonTableName

String toPaimonTableName()

Convert to corresponding Paimon table name.

schema

Schema schema()