Package org.apache.flink.cdc.connectors.tidb.table

Class TiKVReadableMetadata

java.lang.Object

org.apache.flink.cdc.connectors.tidb.table.TiKVReadableMetadata

public class TiKVReadableMetadata
extends Object

Defines the supported metadata columns for TiDBTableSource.

Method Summary

Modifier and Type	Method	Description
static TiKVReadableMetadata	createDatabaseNameMetadata(String database)	Name of the database that contain the row.
static TiKVReadableMetadata	createOpTsMetadata()	It indicates the time that the change was made in the database.
static TiKVReadableMetadata	createTableNameMetadata(String tableName)	Name of the table that contain the row.
static TiKVReadableMetadata[]	createTiKVReadableMetadata(String database, String tableName)
TiKVMetadataConverter	getConverter()
org.apache.flink.table.types.DataType	getDataType()
String	getKey()

Methods inherited from class java.lang.Object

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

Method Detail

getKey

public String getKey()

getDataType

public org.apache.flink.table.types.DataType getDataType()

getConverter

public TiKVMetadataConverter getConverter()

createTableNameMetadata

public static TiKVReadableMetadata createTableNameMetadata(String tableName)

Name of the table that contain the row.

createDatabaseNameMetadata

public static TiKVReadableMetadata createDatabaseNameMetadata(String database)

Name of the database that contain the row.

createOpTsMetadata

public static TiKVReadableMetadata createOpTsMetadata()

It indicates the time that the change was made in the database. If the record is read from snapshot of the table instead of the change stream, the value is always 0.

createTiKVReadableMetadata

public static TiKVReadableMetadata[] createTiKVReadableMetadata(String database,
                                                                String tableName)