org.apache.paimon.flink.action.cdc

Class TableNameConverter

java.lang.Object

org.apache.paimon.flink.action.cdc.TableNameConverter

All Implemented Interfaces:

Serializable

public class TableNameConverter
extends Object
implements Serializable

Used to convert a MySQL source table name to corresponding Paimon table name.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TableNameConverter(boolean caseSensitive)
TableNameConverter(boolean caseSensitive, boolean mergeShards, Map<String,String> dbPrefix, Map<String,String> dbSuffix, String prefix, String suffix, Map<String,String> tableMapping)
TableNameConverter(boolean caseSensitive, boolean mergeShards, String prefix, String suffix, Map<String,String> tableMapping)

Method Summary

Modifier and Type	Method and Description
String	convert(Identifier originIdentifier)
String	convert(String originDbName, String originTblName)

Methods inherited from class java.lang.Object

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

Constructor Detail

TableNameConverter

public TableNameConverter(boolean caseSensitive)

TableNameConverter

public TableNameConverter(boolean caseSensitive,
                          boolean mergeShards,
                          String prefix,
                          String suffix,
                          Map<String,String> tableMapping)

TableNameConverter

public TableNameConverter(boolean caseSensitive,
                          boolean mergeShards,
                          Map<String,String> dbPrefix,
                          Map<String,String> dbSuffix,
                          String prefix,
                          String suffix,
                          Map<String,String> tableMapping)

Method Detail

convert

public String convert(String originDbName,
                      String originTblName)

convert

public String convert(Identifier originIdentifier)