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, String prefix, String suffix)

Method Summary

Modifier and Type	Method and Description
String	convert(Identifier originIdentifier)
String	convert(String originName)

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)

Method Detail

convert

public String convert(String originName)

convert

public String convert(Identifier originIdentifier)