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

Class AllMergedJdbcTableInfo

java.lang.Object

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

All Implemented Interfaces:

JdbcTableInfo

public class AllMergedJdbcTableInfo
extends Object
implements JdbcTableInfo

Describe a table whose schema is merged from all source tables.

Constructor Summary

Constructors

Constructor and Description
AllMergedJdbcTableInfo()

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.
AllMergedJdbcTableInfo	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

AllMergedJdbcTableInfo

public AllMergedJdbcTableInfo()

Method Detail

init

public void init(Identifier identifier,
                 Schema schema)

merge

public AllMergedJdbcTableInfo 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