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

Class UnmergedJdbcTableInfo

java.lang.Object

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

All Implemented Interfaces:

JdbcTableInfo

public class UnmergedJdbcTableInfo
extends Object
implements JdbcTableInfo

Describe a table that is not merged.

Constructor Summary

Constructors

Constructor and Description
UnmergedJdbcTableInfo(Identifier identifier, Schema schema)

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UnmergedJdbcTableInfo

public UnmergedJdbcTableInfo(Identifier identifier,
                             Schema schema)

Method Detail

location

public String location()

Description copied from interface: JdbcTableInfo

To indicate where is the table from.

Specified by:

location in interface JdbcTableInfo

identifiers

public List<Identifier> identifiers()

Description copied from interface: JdbcTableInfo

Return all MySQL table identifiers that build this schema.

Specified by:

identifiers in interface JdbcTableInfo

tableName

public String tableName()

Specified by:

tableName in interface JdbcTableInfo

toPaimonTableName

public String toPaimonTableName()

Description copied from interface: JdbcTableInfo

Convert to corresponding Paimon table name.

Specified by:

toPaimonTableName in interface JdbcTableInfo

schema

public Schema schema()

Specified by:

schema in interface JdbcTableInfo