org.apache.flink.cdc.common.event

类 TableId

java.lang.Object

org.apache.flink.cdc.common.event.TableId

所有已实现的接口:

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

另请参阅:

序列化表格

方法概要

限定符和类型	方法和说明
boolean	equals(Object o)
String	getNamespace()
String	getSchemaName()
String	getTableName()
int	hashCode()
String	identifier()
static TableId	parse(String tableId)
static TableId	tableId(String tableName) The mapping relationship for external systems. e.g.
static TableId	tableId(String schemaName, String tableName) The mapping relationship for external systems. e.g.
static TableId	tableId(String namespace, String schemaName, String tableName) The mapping relationship for external systems. e.g.
String	toString()

从类继承的方法 java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

方法详细资料

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

parse

public static TableId parse(String tableId)

identifier

public String identifier()

getNamespace

@Nullable
public String getNamespace()

getSchemaName

@Nullable
public String getSchemaName()

getTableName

public String getTableName()

equals

public boolean equals(Object o)

覆盖:

equals 在类中 Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object

toString

public String toString()

覆盖:

toString 在类中 Object