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

Class ShardsMergedJdbcTableInfo

java.lang.Object

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

All Implemented Interfaces:

JdbcTableInfo

public class ShardsMergedJdbcTableInfo
extends Object
implements JdbcTableInfo

Describe a table whose schema is merged from shards (tables with the same name but in different database).

Constructor Summary

Constructors

Constructor and Description
ShardsMergedJdbcTableInfo()

Method Summary

Modifier and Type	Method and Description
List<Identifier>	identifiers() Return all MySQL table identifiers that build this schema.
void	init(Identifier identifier, Schema schema)
String	location() To indicate where is the table from.
ShardsMergedJdbcTableInfo	merge(Identifier otherTableId, Schema other)
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

ShardsMergedJdbcTableInfo

public ShardsMergedJdbcTableInfo()

Method Detail

init

public void init(Identifier identifier,
                 Schema schema)

merge

public ShardsMergedJdbcTableInfo merge(Identifier otherTableId,
                                       Schema other)

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