类的使用
org.apache.flink.cdc.common.event.TableId

使用TableId的程序包

程序包	说明
org.apache.flink.cdc.common.event
org.apache.flink.cdc.common.function
org.apache.flink.cdc.common.schema
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.common.source
org.apache.flink.cdc.common.utils

org.apache.flink.cdc.common.event中TableId的使用

返回TableId的org.apache.flink.cdc.common.event中的方法

限定符和类型	方法和说明
static TableId	TableId.parse(String tableId)
TableId	DropColumnEvent.tableId()
TableId	CreateTableEvent.tableId()
TableId	DropTableEvent.tableId()
TableId	TruncateTableEvent.tableId()
TableId	RenameColumnEvent.tableId()
TableId	ChangeEvent.tableId() Describes the database table corresponding to the occurrence of a change event.
TableId	AlterColumnTypeEvent.tableId()
TableId	AddColumnEvent.tableId()
TableId	DataChangeEvent.tableId()
static TableId	TableId.tableId(String tableName) The mapping relationship for external systems. e.g.
static TableId	TableId.tableId(String schemaName, String tableName) The mapping relationship for external systems. e.g.
static TableId	TableId.tableId(String namespace, String schemaName, String tableName) The mapping relationship for external systems. e.g.

返回变量类型为TableId的类型的org.apache.flink.cdc.common.event中的方法

限定符和类型	方法和说明
List<TableId>	FlushEvent.getTableIds()

参数类型为TableId的org.apache.flink.cdc.common.event中的方法

限定符和类型	方法和说明
SchemaChangeEvent	DropColumnEvent.copy(TableId newTableId)
SchemaChangeEvent	CreateTableEvent.copy(TableId newTableId)
SchemaChangeEvent	DropTableEvent.copy(TableId newTableId)
SchemaChangeEvent	TruncateTableEvent.copy(TableId newTableId)
SchemaChangeEvent	RenameColumnEvent.copy(TableId newTableId)
SchemaChangeEvent	SchemaChangeEvent.copy(TableId newTableId) Creates a copy of SchemaChangeEvent with new TableId.
SchemaChangeEvent	AlterColumnTypeEvent.copy(TableId newTableId)
SchemaChangeEvent	AddColumnEvent.copy(TableId newTableId)
static DataChangeEvent	DataChangeEvent.deleteEvent(TableId tableId, RecordData before) Creates a DataChangeEvent instance that describes the delete event.
static DataChangeEvent	DataChangeEvent.deleteEvent(TableId tableId, RecordData before, Map<String,String> meta) Creates a DataChangeEvent instance that describes the delete event with meta info.
static DataChangeEvent	DataChangeEvent.insertEvent(TableId tableId, RecordData after) Creates a DataChangeEvent instance that describes the insert event.
static DataChangeEvent	DataChangeEvent.insertEvent(TableId tableId, RecordData after, Map<String,String> meta) Creates a DataChangeEvent instance that describes the insert event with meta info.
static DataChangeEvent	DataChangeEvent.replaceEvent(TableId tableId, RecordData after) Creates a DataChangeEvent instance that describes the replace event.
static DataChangeEvent	DataChangeEvent.replaceEvent(TableId tableId, RecordData after, Map<String,String> meta) Creates a DataChangeEvent instance that describes the replace event with meta info.
static DataChangeEvent	DataChangeEvent.route(DataChangeEvent dataChangeEvent, TableId tableId) Updates the TableId info of current data change event.
static DataChangeEvent	DataChangeEvent.updateEvent(TableId tableId, RecordData before, RecordData after) Creates a DataChangeEvent instance that describes the update event.
static DataChangeEvent	DataChangeEvent.updateEvent(TableId tableId, RecordData before, RecordData after, Map<String,String> meta) Creates a DataChangeEvent instance that describes the update event with meta info.

参数类型为TableId的org.apache.flink.cdc.common.event中的构造器

构造器和说明
AddColumnEvent(TableId tableId, List<AddColumnEvent.ColumnWithPosition> addedColumns)
AlterColumnTypeEvent(TableId tableId, Map<String,DataType> typeMapping)
AlterColumnTypeEvent(TableId tableId, Map<String,DataType> typeMapping, Map<String,DataType> oldTypeMapping)
CreateTableEvent(TableId tableId, Schema schema)
DropColumnEvent(TableId tableId, List<String> droppedColumnNames)
DropTableEvent(TableId tableId)
RenameColumnEvent(TableId tableId, Map<String,String> nameMapping)
TruncateTableEvent(TableId tableId)

类型变量类型为TableId的org.apache.flink.cdc.common.event中的构造器参数

构造器和说明
FlushEvent(int sourceSubTaskId, List<TableId> tableIds, SchemaChangeEventType schemaChangeEventType)

org.apache.flink.cdc.common.function中TableId的使用

参数类型为TableId的org.apache.flink.cdc.common.function中的方法

限定符和类型	方法和说明
HashFunction<T>	HashFunctionProvider.getHashFunction(TableId tableId, Schema schema) Gets a hash function based on the given table ID and schema, to help PrePartitionOperator to shuffle DataChangeEvent to designated subtask.

org.apache.flink.cdc.common.schema中TableId的使用

参数类型为TableId的org.apache.flink.cdc.common.schema中的方法

限定符和类型	方法和说明
boolean	TableFilter.isIncluded(TableId tableId) Determines whether the given table should be included.
boolean	Selectors.isMatch(TableId tableId) Match the TableId against the Selectors

类型变量类型为TableId的org.apache.flink.cdc.common.schema中的方法参数

限定符和类型	方法和说明
static TableFilter	TableFilter.fromPredicate(java.util.function.Predicate<TableId> predicate) Creates a TableFilter from the given predicate.

org.apache.flink.cdc.common.sink中TableId的使用

参数类型为TableId的org.apache.flink.cdc.common.sink中的方法

限定符和类型	方法和说明
HashFunction<DataChangeEvent>	DefaultDataChangeEventHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)

org.apache.flink.cdc.common.source中TableId的使用

返回变量类型为TableId的类型的org.apache.flink.cdc.common.source中的方法

限定符和类型	方法和说明
List<TableId>	MetadataAccessor.listTables(String namespace, String schemaName) List tables by namespace and schema from external systems.

参数类型为TableId的org.apache.flink.cdc.common.source中的方法

限定符和类型	方法和说明
Schema	MetadataAccessor.getTableSchema(TableId tableId) Get the Schema of the given table.

org.apache.flink.cdc.common.utils中TableId的使用

参数类型为TableId的org.apache.flink.cdc.common.utils中的方法

限定符和类型	方法和说明
static List<SchemaChangeEvent>	SchemaMergingUtils.getSchemaDifference(TableId tableId, Schema beforeSchema, Schema afterSchema) Generating what schema change events we need to do by converting compatible beforeSchema to afterSchema.
static DataChangeEvent	ChangeEventUtils.recreateDataChangeEvent(DataChangeEvent dataChangeEvent, TableId tableId)
static SchemaChangeEvent	ChangeEventUtils.recreateSchemaChangeEvent(SchemaChangeEvent schemaChangeEvent, TableId tableId)