Package org.apache.flink.cdc.common.event

Class TableId

  • All Implemented Interfaces:
    Serializable
    @PublicEvolving
public class TableId
extends Object
implements Serializable
    The unique identifier used to represent the path of external table or external data collection, all external system data collection could map to a dedicated TableId.
    • TableId contains at most three parts, it will be treated as namespace, schema name and table name.
    • TableId could contain two parts, it will be treated as schema name and table name.
    • TableId could contain only one part, it will be treated as table name.

    Connectors need to establish the mapping between TableId and external data collection object path. For example,

    • The mapping relationship for Oracle is: (database, schema, table).
    • The mapping relationship for MySQL or Doris is: (database, table).
    • The mapping relationship for Kafka is: (topic).
    See Also:
    Serialized Form

    • Method Detail

      • tableId

        public static TableId tableId​(String namespace,
                              String schemaName,
                              String tableName)
        The mapping relationship for external systems. e.g. Oracle (database, schema, table).

      • tableId

        public static TableId tableId​(String schemaName,
                              String tableName)
        The mapping relationship for external systems. e.g. MySQL (database, table).

      • tableId

        public static TableId tableId​(String tableName)
        The mapping relationship for external systems. e.g. Kafka (topic).

      • identifier

        public String identifier()

      • getTableName

        public String getTableName()

      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object