Uses of Class
org.apache.flink.cdc.common.event.TableId

Packages that use TableId

Package	Description
org.apache.flink.cdc.common.event
org.apache.flink.cdc.common.function
org.apache.flink.cdc.common.route
org.apache.flink.cdc.common.schema
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.common.source
org.apache.flink.cdc.common.source.discover
org.apache.flink.cdc.common.utils
org.apache.flink.cdc.connectors.doris.utils
org.apache.flink.cdc.connectors.elasticsearch.config
org.apache.flink.cdc.connectors.elasticsearch.serializer
org.apache.flink.cdc.connectors.fluss.sink
org.apache.flink.cdc.connectors.fluss.source
org.apache.flink.cdc.connectors.fluss.source.discover
org.apache.flink.cdc.connectors.hudi.sink.bucket
org.apache.flink.cdc.connectors.hudi.sink.event
org.apache.flink.cdc.connectors.hudi.sink.util
org.apache.flink.cdc.connectors.iceberg.sink.v2
org.apache.flink.cdc.connectors.kafka.json
org.apache.flink.cdc.connectors.maxcompute.sink
org.apache.flink.cdc.connectors.maxcompute.utils
org.apache.flink.cdc.connectors.mysql.source
org.apache.flink.cdc.connectors.mysql.utils
org.apache.flink.cdc.connectors.oceanbase.sink
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.oracle.utils
org.apache.flink.cdc.connectors.paimon.sink
org.apache.flink.cdc.connectors.paimon.sink.v2
org.apache.flink.cdc.connectors.paimon.sink.v2.bucket
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.postgres.utils
org.apache.flink.cdc.connectors.sqlserver.source
org.apache.flink.cdc.connectors.sqlserver.utils
org.apache.flink.cdc.connectors.starrocks.sink
org.apache.flink.cdc.connectors.values
org.apache.flink.cdc.connectors.values.source
org.apache.flink.cdc.debezium.event
org.apache.flink.cdc.runtime.operators.schema.common
org.apache.flink.cdc.runtime.operators.schema.common.event
org.apache.flink.cdc.runtime.operators.schema.distributed
org.apache.flink.cdc.runtime.operators.schema.distributed.event
org.apache.flink.cdc.runtime.operators.schema.regular
org.apache.flink.cdc.runtime.operators.schema.regular.event
org.apache.flink.cdc.runtime.operators.sink
org.apache.flink.cdc.runtime.operators.transform
org.apache.flink.cdc.runtime.operators.transform.exceptions
org.apache.flink.cdc.runtime.serializer

Uses of TableId in org.apache.flink.cdc.common.event

Methods in org.apache.flink.cdc.common.event that return TableId

Modifier and Type	Method	Description
static TableId	TableId.parse(String tableId)
TableId	AddColumnEvent.tableId()
TableId	AlterColumnTypeEvent.tableId()
TableId	AlterTableCommentEvent.tableId()
TableId	ChangeEvent.tableId()	Describes the database table corresponding to the occurrence of a change event.
TableId	CreateTableEvent.tableId()
TableId	DataChangeEvent.tableId()
TableId	DropColumnEvent.tableId()
TableId	DropTableEvent.tableId()
TableId	RenameColumnEvent.tableId()
static TableId	TableId.tableId(String tableName)	The mapping relationship for external systems.
static TableId	TableId.tableId(String schemaName, String tableName)	The mapping relationship for external systems.
static TableId	TableId.tableId(String namespace, String schemaName, String tableName)	The mapping relationship for external systems.
TableId	TruncateTableEvent.tableId()

Methods in org.apache.flink.cdc.common.event that return types with arguments of type TableId

Modifier and Type	Method	Description
List<TableId>	FlushEvent.getTableIds()

Methods in org.apache.flink.cdc.common.event with parameters of type TableId

Modifier and Type	Method	Description
SchemaChangeEvent	AddColumnEvent.copy(TableId newTableId)
SchemaChangeEvent	AlterColumnTypeEvent.copy(TableId newTableId)
SchemaChangeEvent	AlterTableCommentEvent.copy(TableId newTableId)
SchemaChangeEvent	CreateTableEvent.copy(TableId newTableId)
SchemaChangeEvent	DropColumnEvent.copy(TableId newTableId)
SchemaChangeEvent	DropTableEvent.copy(TableId newTableId)
SchemaChangeEvent	RenameColumnEvent.copy(TableId newTableId)
SchemaChangeEvent	SchemaChangeEvent.copy(TableId newTableId)	Creates a copy of SchemaChangeEvent with new TableId.
SchemaChangeEvent	TruncateTableEvent.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.

Constructors in org.apache.flink.cdc.common.event with parameters of type TableId

Constructor	Description
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)
AlterColumnTypeEvent(TableId tableId, Map<String,DataType> typeMapping, Map<String,DataType> oldTypeMapping, Map<String,String> comments)
AlterTableCommentEvent(TableId tableId, String comment)
CreateTableEvent(TableId tableId, Schema schema)
DropColumnEvent(TableId tableId, List<String> droppedColumnNames)
DropTableEvent(TableId tableId)
RenameColumnEvent(TableId tableId, Map<String,String> nameMapping)
TruncateTableEvent(TableId tableId)

Constructor parameters in org.apache.flink.cdc.common.event with type arguments of type TableId

Constructor	Description
FlushEvent(int sourceSubTaskId, List<TableId> tableIds, SchemaChangeEventType schemaChangeEventType)

Uses of TableId in org.apache.flink.cdc.common.function

Methods in org.apache.flink.cdc.common.function with parameters of type TableId

Modifier and Type	Method	Description
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.

Uses of TableId in org.apache.flink.cdc.common.route

Methods in org.apache.flink.cdc.common.route that return types with arguments of type TableId

Modifier and Type	Method	Description
List<Set<TableId>>	TableIdRouter.groupSourceTablesByRouteRule(Set<TableId> tableIdSet)	Group the source tables that conform to the same routing rule together.
List<TableId>	TableIdRouter.route(TableId sourceTableId)

Methods in org.apache.flink.cdc.common.route with parameters of type TableId

Modifier and Type	Method	Description
List<TableId>	TableIdRouter.route(TableId sourceTableId)

Method parameters in org.apache.flink.cdc.common.route with type arguments of type TableId

Modifier and Type	Method	Description
List<Set<TableId>>	TableIdRouter.groupSourceTablesByRouteRule(Set<TableId> tableIdSet)	Group the source tables that conform to the same routing rule together.

Uses of TableId in org.apache.flink.cdc.common.schema

Methods in org.apache.flink.cdc.common.schema with parameters of type TableId

Modifier and Type	Method	Description
boolean	TableFilter.isIncluded(TableId tableId)	Determines whether the given table should be included.
boolean	Selectors.isMatch(TableId tableId)	Match the TableId against the Selectors.Selectors.

Method parameters in org.apache.flink.cdc.common.schema with type arguments of type TableId

Modifier and Type	Method	Description
static TableFilter	TableFilter.fromPredicate(java.util.function.Predicate<TableId> predicate)	Creates a TableFilter from the given predicate.

Uses of TableId in org.apache.flink.cdc.common.sink

Methods in org.apache.flink.cdc.common.sink with parameters of type TableId

Modifier and Type	Method	Description
Optional<Schema>	ExistingTableSchemaExpansionSupport.getExistingTableSchema(TableId tableId)	Returns the current schema of the target table, or Optional.empty() if the table does not exist.
HashFunction<DataChangeEvent>	DefaultDataChangeEventHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
HashFunction<DataChangeEvent>	ForwardHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
HashFunction<DataChangeEvent>	TableIdHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
DataType	ExistingTableSchemaExpansionSupport.normalizeToTargetDataType(TableId tableId, String columnName, DataType pipelineDataType, Schema existingTargetSchema)	Converts a pipeline type to the canonical CDC representation of the physical type that this applier will create in the existing target table.

Uses of TableId in org.apache.flink.cdc.common.source

Methods in org.apache.flink.cdc.common.source that return types with arguments of type TableId

Modifier and Type	Method	Description
List<TableId>	MetadataAccessor.listTables(String namespace, String schemaName)	List tables by namespace and schema from external systems.

Methods in org.apache.flink.cdc.common.source with parameters of type TableId

Modifier and Type	Method	Description
Schema	MetadataAccessor.getTableSchema(TableId tableId)	Get the Schema of the given table.

Uses of TableId in org.apache.flink.cdc.common.source.discover

Methods in org.apache.flink.cdc.common.source.discover that return types with arguments of type TableId

Modifier and Type	Method	Description
Set<TableId>	JdbcTableDiscoverer.discover()
default Class<TableId>	TableDiscovererFactory.objectIdClass()	Compatibility alias for the old single identifier, now meaning storage-side type.

Uses of TableId in org.apache.flink.cdc.common.utils

Methods in org.apache.flink.cdc.common.utils with parameters of type TableId

Modifier and Type	Method	Description
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)

Uses of TableId in org.apache.flink.cdc.connectors.doris.utils

Methods in org.apache.flink.cdc.connectors.doris.utils with parameters of type TableId

Modifier and Type	Method	Description
static org.apache.flink.api.java.tuple.Tuple2<String,String>	DorisSchemaUtils.getPartitionInfo(Configuration config, Schema schema, TableId tableId)	Get partition info by config.

Uses of TableId in org.apache.flink.cdc.connectors.elasticsearch.config

Methods in org.apache.flink.cdc.connectors.elasticsearch.config that return types with arguments of type TableId

Modifier and Type	Method	Description
Map<TableId,String>	ElasticsearchSinkOptions.getShardingKey()

Constructor parameters in org.apache.flink.cdc.connectors.elasticsearch.config with type arguments of type TableId

Constructor	Description
ElasticsearchSinkOptions(int maxBatchSize, int maxInFlightRequests, int maxBufferedRequests, long maxBatchSizeInBytes, long maxTimeInBufferMS, long maxRecordSizeInBytes, NetworkConfig networkConfig, int version, String username, String password, Map<TableId,String> shardingKey, String shardingSeparator)

Uses of TableId in org.apache.flink.cdc.connectors.elasticsearch.serializer

Methods in org.apache.flink.cdc.connectors.elasticsearch.serializer with parameters of type TableId

Modifier and Type	Method	Description
Map<String,Object>	ElasticsearchEventSerializer.serializeRecord(TableId tableId, RecordData recordData, Schema schema, java.time.ZoneId pipelineZoneId)
String	ElasticsearchEventSerializer.tableSharding(TableId tableId, Schema schema, Map<String,Object> valueMap)

Constructor parameters in org.apache.flink.cdc.connectors.elasticsearch.serializer with type arguments of type TableId

Constructor	Description
ElasticsearchEventSerializer(java.time.ZoneId zoneId, Map<TableId,String> shardingKey, String shardingSeparator)

Uses of TableId in org.apache.flink.cdc.connectors.fluss.sink

Methods in org.apache.flink.cdc.connectors.fluss.sink with parameters of type TableId

Modifier and Type	Method	Description
Optional<Schema>	FlussMetaDataApplier.getExistingTableSchema(TableId tableId)
HashFunction<DataChangeEvent>	FlussHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
DataType	FlussMetaDataApplier.normalizeToTargetDataType(TableId tableId, String columnName, DataType pipelineDataType, Schema existingTargetSchema)

Uses of TableId in org.apache.flink.cdc.connectors.fluss.source

Methods in org.apache.flink.cdc.connectors.fluss.source that return types with arguments of type TableId

Modifier and Type	Method	Description
List<TableId>	FlussMetadataAccessor.listTables(String namespace, String schemaName)

Methods in org.apache.flink.cdc.connectors.fluss.source with parameters of type TableId

Modifier and Type	Method	Description
Schema	FlussMetadataAccessor.getTableSchema(TableId tableId)

Uses of TableId in org.apache.flink.cdc.connectors.fluss.source.discover

Methods in org.apache.flink.cdc.connectors.fluss.source.discover that return types with arguments of type TableId

Modifier and Type	Method	Description
Set<TableId>	FlussDefaultDiscoverer.discover()

Methods in org.apache.flink.cdc.connectors.fluss.source.discover with parameters of type TableId

Modifier and Type	Method	Description
static org.apache.fluss.metadata.TablePath	FlussDefaultDiscoverer.toTablePath(TableId tableId)	Converts a TableId (two-part: schemaName.tableName) to a Fluss TablePath.

Uses of TableId in org.apache.flink.cdc.connectors.hudi.sink.bucket

Constructor parameters in org.apache.flink.cdc.connectors.hudi.sink.bucket with type arguments of type TableId

Constructor	Description
BucketWrapperFlushEvent(int bucket, int sourceSubTaskId, int bucketAssignTaskId, List<TableId> tableIds, SchemaChangeEventType schemaChangeEventType)

Uses of TableId in org.apache.flink.cdc.connectors.hudi.sink.event

Methods in org.apache.flink.cdc.connectors.hudi.sink.event that return TableId

Modifier and Type	Method	Description
TableId	SchemaChangeOperatorEvent.getTableId()	Gets the ID of the table whose schema changed.
TableId	TableAwareCorrespondent.MultiTableInstantTimeRequest.getTableId()
TableId	TableAwareCorrespondent.SchemaChangeRequest.getTableId()
TableId	TableAwareCorrespondent.SchemaChangeResponse.getTableId()

Methods in org.apache.flink.cdc.connectors.hudi.sink.event with parameters of type TableId

Modifier and Type	Method	Description
static TableAwareCorrespondent	TableAwareCorrespondent.getInstance(org.apache.hudi.sink.event.Correspondent correspondent, TableId tableId)	Creates a coordinator correspondent.
Schema	HudiRecordEventSerializer.getSchema(TableId tableId)	Get cached schema for a table.
boolean	HudiRecordEventSerializer.hasSchema(TableId tableId)	Check if schema is cached for a table.
static TableAwareCorrespondent.SchemaChangeResponse	TableAwareCorrespondent.SchemaChangeResponse.of(TableId tableId, boolean success)
boolean	TableAwareCorrespondent.requestSchemaChange(TableId tableId, Schema newSchema)	Send a request to coordinator to apply the schema change.
void	HudiRecordEventSerializer.setSchema(TableId tableId, Schema schema)	Set schema for a table.

Constructors in org.apache.flink.cdc.connectors.hudi.sink.event with parameters of type TableId

Constructor	Description
MultiTableInstantTimeRequest(long checkpointId, TableId tableId)
SchemaChangeOperatorEvent(TableId tableId, Schema newSchema)	Constructs a new SchemaChangeOperatorEvent.
SchemaChangeRequest(TableId tableId, Schema schema)

Uses of TableId in org.apache.flink.cdc.connectors.hudi.sink.util

Methods in org.apache.flink.cdc.connectors.hudi.sink.util with parameters of type TableId

Modifier and Type	Method	Description
static org.apache.flink.configuration.Configuration	ConfigUtils.createTableConfig(org.apache.flink.configuration.Configuration baseConfig, Schema cdcSchema, TableId tableId)

Uses of TableId in org.apache.flink.cdc.connectors.iceberg.sink.v2

Methods in org.apache.flink.cdc.connectors.iceberg.sink.v2 that return TableId

Modifier and Type	Method	Description
TableId	WriteResultWrapper.getTableId()

Constructors in org.apache.flink.cdc.connectors.iceberg.sink.v2 with parameters of type TableId

Constructor	Description
WriteResultWrapper(org.apache.iceberg.io.WriteResult writeResult, TableId tableId, long checkpointId, String jobId, String operatorId)
WriteResultWrapper(org.apache.iceberg.io.WriteResult writeResult, TableId tableId, long checkpointId, String jobId, String operatorId, int batchIndex)

Uses of TableId in org.apache.flink.cdc.connectors.kafka.json

Constructors in org.apache.flink.cdc.connectors.kafka.json with parameters of type TableId

Constructor	Description
TableSchemaInfo(TableId tableId, Schema schema, org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData> serializationSchema, java.time.ZoneId zoneId)

Uses of TableId in org.apache.flink.cdc.connectors.maxcompute.sink

Methods in org.apache.flink.cdc.connectors.maxcompute.sink with parameters of type TableId

Modifier and Type	Method	Description
HashFunction<DataChangeEvent>	MaxComputeHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)

Uses of TableId in org.apache.flink.cdc.connectors.maxcompute.utils

Methods in org.apache.flink.cdc.connectors.maxcompute.utils with parameters of type TableId

Modifier and Type	Method	Description
static void	SchemaEvolutionUtils.addColumns(MaxComputeOptions options, TableId tableId, List<AddColumnEvent.ColumnWithPosition> columns)	equals to run a sql like: 'alter table table_name add columns (col_name1 type1 comment [, col_name2 type2 ...]);'.
static void	SchemaEvolutionUtils.alterColumnType(MaxComputeOptions options, TableId tableId, Map<String,DataType> typeMapping, Map<String,String> comments)	equals to run a sql like: 'alter table table_name change column old_column_name new_column_name new_data_type;'.
static void	SchemaEvolutionUtils.alterTableComment(MaxComputeOptions options, TableId tableId, String comment)
static void	SchemaEvolutionUtils.createTable(MaxComputeOptions options, TableId tableId, Schema schema)	equals to run a sql like: create table table_name (col_name1 type1 comment [, col_name2 type2 ...]);.
static void	SchemaEvolutionUtils.dropColumn(MaxComputeOptions options, TableId tableId, List<String> droppedColumnNames)	equals to run a sql like: 'alter table table_name drop columns col_name1[, col_name2...];'.
static void	SchemaEvolutionUtils.dropTable(MaxComputeOptions options, TableId tableId)
static String	MaxComputeUtils.getSchema(MaxComputeOptions options, TableId tableId)
static com.aliyun.odps.Table	MaxComputeUtils.getTable(MaxComputeOptions maxComputeOptions, TableId tableId)
static com.aliyun.odps.TableSchema	MaxComputeUtils.getTableSchema(MaxComputeOptions options, TableId tableId)
static boolean	MaxComputeUtils.isTableExist(MaxComputeOptions maxComputeOptions, TableId tableId)
static void	SchemaEvolutionUtils.renameColumn(MaxComputeOptions options, TableId tableId, Map<String,String> nameMapping)	equals to run a sql like: 'alter table table_name change column old_col_name rename to new_col_name;'.
static void	SchemaEvolutionUtils.truncateTable(MaxComputeOptions options, TableId tableId)

Uses of TableId in org.apache.flink.cdc.connectors.mysql.source

Methods in org.apache.flink.cdc.connectors.mysql.source that return TableId

Modifier and Type	Method	Description
protected TableId	MySqlEventDeserializer.getTableId(org.apache.kafka.connect.source.SourceRecord record)

Methods in org.apache.flink.cdc.connectors.mysql.source that return types with arguments of type TableId

Modifier and Type	Method	Description
List<TableId>	MySqlMetadataAccessor.listTables(String namespace, String dbName)	List tables from MySQL.

Methods in org.apache.flink.cdc.connectors.mysql.source with parameters of type TableId

Modifier and Type	Method	Description
Schema	MySqlMetadataAccessor.getTableSchema(TableId tableId)	Get the Schema of the given table.

Uses of TableId in org.apache.flink.cdc.connectors.mysql.utils

Methods in org.apache.flink.cdc.connectors.mysql.utils that return types with arguments of type TableId

Modifier and Type	Method	Description
static List<TableId>	MySqlSchemaUtils.listTables(io.debezium.jdbc.JdbcConnection jdbc, String dbName)
static List<TableId>	MySqlSchemaUtils.listTables(MySqlSourceConfig sourceConfig, String dbName)

Methods in org.apache.flink.cdc.connectors.mysql.utils with parameters of type TableId

Modifier and Type	Method	Description
static Schema	MySqlSchemaUtils.getTableSchema(io.debezium.connector.mysql.MySqlPartition partition, TableId tableId, MySqlSourceConfig sourceConfig, MySqlConnection jdbc)
static Schema	MySqlSchemaUtils.getTableSchema(MySqlSourceConfig sourceConfig, io.debezium.connector.mysql.MySqlPartition partition, TableId tableId)
static io.debezium.relational.TableId	MySqlSchemaUtils.toDbzTableId(TableId tableId)

Uses of TableId in org.apache.flink.cdc.connectors.oceanbase.sink

Methods in org.apache.flink.cdc.connectors.oceanbase.sink with parameters of type TableId

Modifier and Type	Method	Description
static OceanBaseTable	OceanBaseUtils.toOceanBaseTable(TableId tableId, Schema schema)	Convert a source table to OceanBaseTable.

Uses of TableId in org.apache.flink.cdc.connectors.oracle.source

Methods in org.apache.flink.cdc.connectors.oracle.source that return TableId

Modifier and Type	Method	Description
protected TableId	OracleEventDeserializer.getTableId(org.apache.kafka.connect.source.SourceRecord record)

Methods in org.apache.flink.cdc.connectors.oracle.source that return types with arguments of type TableId

Modifier and Type	Method	Description
List<TableId>	OracleMetadataAccessor.listTables(String namespace, String dbName)	List tables from oracle.

Methods in org.apache.flink.cdc.connectors.oracle.source with parameters of type TableId

Modifier and Type	Method	Description
Schema	OracleMetadataAccessor.getTableSchema(TableId tableId)	Get the Schema of the given table.

Uses of TableId in org.apache.flink.cdc.connectors.oracle.utils

Methods in org.apache.flink.cdc.connectors.oracle.utils that return types with arguments of type TableId

Modifier and Type	Method	Description
static List<TableId>	OracleSchemaUtils.listTables(io.debezium.jdbc.JdbcConnection jdbc, String schemaName)
static List<TableId>	OracleSchemaUtils.listTables(OracleSourceConfig sourceConfig, String dbName)

Methods in org.apache.flink.cdc.connectors.oracle.utils with parameters of type TableId

Modifier and Type	Method	Description
static Schema	OracleSchemaUtils.getTableSchema(TableId tableId, OracleSourceConfig sourceConfig)
static io.debezium.relational.TableId	OracleSchemaUtils.toDbzTableId(TableId tableId)

Uses of TableId in org.apache.flink.cdc.connectors.paimon.sink

Methods in org.apache.flink.cdc.connectors.paimon.sink with parameters of type TableId

Modifier and Type	Method	Description
Optional<Schema>	PaimonMetadataApplier.getExistingTableSchema(TableId tableId)
HashFunction<DataChangeEvent>	PaimonHashFunctionProvider.getHashFunction(TableId tableId, Schema schema)
DataType	PaimonMetadataApplier.normalizeToTargetDataType(TableId tableId, String columnName, DataType pipelineDataType, Schema existingTargetSchema)

Uses of TableId in org.apache.flink.cdc.connectors.paimon.sink.v2

Methods in org.apache.flink.cdc.connectors.paimon.sink.v2 with parameters of type TableId

Modifier and Type	Method	Description
static org.apache.paimon.catalog.Identifier	PaimonWriterHelper.identifierFromTableId(TableId tableId)

Uses of TableId in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket

Methods in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket that return TableId

Modifier and Type	Method	Description
TableId	BucketWrapperChangeEvent.tableId()

Constructor parameters in org.apache.flink.cdc.connectors.paimon.sink.v2.bucket with type arguments of type TableId

Constructor	Description
BucketWrapperFlushEvent(int bucket, int sourceSubTaskId, int bucketAssignTaskId, List<TableId> tableIds, SchemaChangeEventType schemaChangeEventType)

Uses of TableId in org.apache.flink.cdc.connectors.postgres.source

Methods in org.apache.flink.cdc.connectors.postgres.source that return TableId

Modifier and Type	Method	Description
protected TableId	PostgresEventDeserializer.getTableId(org.apache.kafka.connect.source.SourceRecord record)

Methods in org.apache.flink.cdc.connectors.postgres.source that return types with arguments of type TableId

Modifier and Type	Method	Description
List<TableId>	PostgresMetadataAccessor.listTables(String namespace, String dbName)	List tables from postgres.

Methods in org.apache.flink.cdc.connectors.postgres.source with parameters of type TableId

Modifier and Type	Method	Description
Schema	PostgresMetadataAccessor.getTableSchema(TableId tableId)	Get the Schema of the given table.

Uses of TableId in org.apache.flink.cdc.connectors.postgres.utils

Methods in org.apache.flink.cdc.connectors.postgres.utils that return TableId

Modifier and Type	Method	Description
static TableId	PostgresSchemaUtils.toCdcTableId(io.debezium.relational.TableId dbzTableId)
static TableId	PostgresSchemaUtils.toCdcTableId(io.debezium.relational.TableId dbzTableId, String databaseName, boolean includeDatabaseInTableId)

Methods in org.apache.flink.cdc.connectors.postgres.utils that return types with arguments of type TableId

Modifier and Type	Method	Description
static List<TableId>	PostgresSchemaUtils.listTables(PostgresSourceConfig sourceConfig, String dbName)

Methods in org.apache.flink.cdc.connectors.postgres.utils with parameters of type TableId

Modifier and Type	Method	Description
static Schema	PostgresSchemaUtils.getTableSchema(TableId tableId, PostgresSourceConfig sourceConfig, PostgresConnection jdbc)
static Schema	PostgresSchemaUtils.getTableSchema(PostgresSourceConfig sourceConfig, TableId tableId)
static io.debezium.relational.TableId	PostgresSchemaUtils.toDbzTableId(TableId tableId)

Uses of TableId in org.apache.flink.cdc.connectors.sqlserver.source

Methods in org.apache.flink.cdc.connectors.sqlserver.source that return TableId

Modifier and Type	Method	Description
protected TableId	SqlServerEventDeserializer.getTableId(org.apache.kafka.connect.source.SourceRecord record)

Methods in org.apache.flink.cdc.connectors.sqlserver.source that return types with arguments of type TableId

Modifier and Type	Method	Description
List<TableId>	SqlServerMetadataAccessor.listTables(String namespace, String schemaName)	List tables from SQL Server.

Methods in org.apache.flink.cdc.connectors.sqlserver.source with parameters of type TableId

Modifier and Type	Method	Description
Schema	SqlServerMetadataAccessor.getTableSchema(TableId tableId)	Get the Schema of the given table.

Uses of TableId in org.apache.flink.cdc.connectors.sqlserver.utils

Methods in org.apache.flink.cdc.connectors.sqlserver.utils that return TableId

Modifier and Type	Method	Description
static TableId	SqlServerSchemaUtils.toCdcTableId(io.debezium.relational.TableId dbzTableId)

Methods in org.apache.flink.cdc.connectors.sqlserver.utils that return types with arguments of type TableId

Modifier and Type	Method	Description
static List<TableId>	SqlServerSchemaUtils.listTables(SqlServerSourceConfig sourceConfig, String dbName, String schemaName)

Methods in org.apache.flink.cdc.connectors.sqlserver.utils with parameters of type TableId

Modifier and Type	Method	Description
static Schema	SqlServerSchemaUtils.getTableSchema(TableId tableId, io.debezium.connector.sqlserver.SqlServerConnection jdbc, SqlServerDialect dialect)
static Schema	SqlServerSchemaUtils.getTableSchema(SqlServerSourceConfig sourceConfig, TableId tableId)
static io.debezium.relational.TableId	SqlServerSchemaUtils.toDbzTableId(TableId tableId)

Uses of TableId in org.apache.flink.cdc.connectors.starrocks.sink

Methods in org.apache.flink.cdc.connectors.starrocks.sink with parameters of type TableId

Modifier and Type	Method	Description
static com.starrocks.connector.flink.catalog.StarRocksTable	StarRocksUtils.toStarRocksTable(TableId tableId, Schema schema, TableCreateConfig tableCreateConfig)	Convert a source table to StarRocksTable.

Uses of TableId in org.apache.flink.cdc.connectors.values

Methods in org.apache.flink.cdc.connectors.values that return types with arguments of type TableId

Modifier and Type	Method	Description
List<TableId>	ValuesDatabase.ValuesMetadataAccessor.listTables(String namespace, String schemaName)

Methods in org.apache.flink.cdc.connectors.values with parameters of type TableId

Modifier and Type	Method	Description
static List<String>	ValuesDatabase.getResults(TableId tableId)
static Schema	ValuesDatabase.getTableSchema(TableId tableId)
Schema	ValuesDatabase.ValuesMetadataAccessor.getTableSchema(TableId tableId)

Uses of TableId in org.apache.flink.cdc.connectors.values.source

Fields in org.apache.flink.cdc.connectors.values.source declared as TableId

Modifier and Type	Field	Description
static TableId	ValuesDataSourceHelper.TABLE_1
static TableId	ValuesDataSourceHelper.TABLE_2

Uses of TableId in org.apache.flink.cdc.debezium.event

Methods in org.apache.flink.cdc.debezium.event that return TableId

Modifier and Type	Method	Description
protected abstract TableId	SourceRecordEventDeserializer.getTableId(org.apache.kafka.connect.source.SourceRecord record)	Get TableId from data change record.

Uses of TableId in org.apache.flink.cdc.runtime.operators.schema.common

Methods in org.apache.flink.cdc.runtime.operators.schema.common that return types with arguments of type TableId

Modifier and Type	Method	Description
static Set<TableId>	SchemaDerivator.getAffectedEvolvedTables(TableIdRouter tableIdRouter, Set<TableId> changedUpstreamTables)	Get affected evolved table IDs based on changed upstream tables.
Set<TableId>	SchemaManager.getAllOriginalTables()
static Set<TableId>	SchemaDerivator.reverseLookupDependingUpstreamTables(TableIdRouter tableIdRouter, TableId evolvedTableId, Set<TableId> upstreamSchemaTables)	For an evolved table ID, reverse lookup all upstream tables that it depends on.
static Set<TableId>	SchemaDerivator.reverseLookupDependingUpstreamTables(TableIdRouter tableIdRouter, TableId evolvedTableId, org.apache.flink.shaded.guava31.com.google.common.collect.Table<TableId,Integer,Schema> upstreamSchemaTable)	For an evolved table ID, reverse lookup all upstream tables that it depends on.

Methods in org.apache.flink.cdc.runtime.operators.schema.common with parameters of type TableId

Modifier and Type	Method	Description
void	SchemaRegistry.emplaceEvolvedSchema(TableId tableId, Schema schema)
void	SchemaRegistry.emplaceOriginalSchema(TableId tableId, Schema schema)
boolean	SchemaManager.evolvedSchemaExists(TableId tableId)
Schema	SchemaManager.getEvolvedSchema(TableId tableId, int version)	Get schema at the specified version of a table.
Optional<Schema>	SchemaManager.getLatestEvolvedSchema(TableId tableId)	Get the latest evolved schema of the specified table.
Optional<Schema>	SchemaManager.getLatestOriginalSchema(TableId tableId)	Get the latest original schema of the specified table.
Schema	SchemaManager.getOriginalSchema(TableId tableId, int version)	Get schema at the specified version of a table.
boolean	SchemaManager.originalSchemaExists(TableId tableId)
void	SchemaManager.registerNewEvolvedSchema(TableId tableId, Schema newSchema)
void	SchemaManager.registerNewOriginalSchema(TableId tableId, Schema newSchema)
static Set<Schema>	SchemaDerivator.reverseLookupDependingUpstreamSchemas(TableIdRouter tableIdRouter, TableId evolvedTableId, SchemaManager schemaManager)	For an evolved table ID, reverse lookup all upstream schemas that needs to be fit in.
static Set<Schema>	SchemaDerivator.reverseLookupDependingUpstreamSchemas(TableIdRouter tableIdRouter, TableId evolvedTableId, org.apache.flink.shaded.guava31.com.google.common.collect.Table<TableId,Integer,Schema> upstreamSchemaTable)	For an evolved table ID, reverse lookup all upstream schemas that needs to be fit in.
static Set<TableId>	SchemaDerivator.reverseLookupDependingUpstreamTables(TableIdRouter tableIdRouter, TableId evolvedTableId, Set<TableId> upstreamSchemaTables)	For an evolved table ID, reverse lookup all upstream tables that it depends on.
static Set<TableId>	SchemaDerivator.reverseLookupDependingUpstreamTables(TableIdRouter tableIdRouter, TableId evolvedTableId, org.apache.flink.shaded.guava31.com.google.common.collect.Table<TableId,Integer,Schema> upstreamSchemaTable)	For an evolved table ID, reverse lookup all upstream tables that it depends on.
boolean	SchemaManager.schemaExists(Map<TableId,SortedMap<Integer,Schema>> schemaMap, TableId tableId)

Method parameters in org.apache.flink.cdc.runtime.operators.schema.common with type arguments of type TableId

Modifier and Type	Method	Description
static Set<TableId>	SchemaDerivator.getAffectedEvolvedTables(TableIdRouter tableIdRouter, Set<TableId> changedUpstreamTables)	Get affected evolved table IDs based on changed upstream tables.
static Set<Schema>	SchemaDerivator.reverseLookupDependingUpstreamSchemas(TableIdRouter tableIdRouter, TableId evolvedTableId, org.apache.flink.shaded.guava31.com.google.common.collect.Table<TableId,Integer,Schema> upstreamSchemaTable)	For an evolved table ID, reverse lookup all upstream schemas that needs to be fit in.
static Set<TableId>	SchemaDerivator.reverseLookupDependingUpstreamTables(TableIdRouter tableIdRouter, TableId evolvedTableId, Set<TableId> upstreamSchemaTables)	For an evolved table ID, reverse lookup all upstream tables that it depends on.
static Set<TableId>	SchemaDerivator.reverseLookupDependingUpstreamTables(TableIdRouter tableIdRouter, TableId evolvedTableId, org.apache.flink.shaded.guava31.com.google.common.collect.Table<TableId,Integer,Schema> upstreamSchemaTable)	For an evolved table ID, reverse lookup all upstream tables that it depends on.
boolean	SchemaManager.schemaExists(Map<TableId,SortedMap<Integer,Schema>> schemaMap, TableId tableId)

Constructor parameters in org.apache.flink.cdc.runtime.operators.schema.common with type arguments of type TableId

Constructor	Description
SchemaManager(Map<TableId,SortedMap<Integer,Schema>> originalSchemas, Map<TableId,SortedMap<Integer,Schema>> evolvedSchemas, SchemaChangeBehavior behavior)

Uses of TableId in org.apache.flink.cdc.runtime.operators.schema.common.event

Methods in org.apache.flink.cdc.runtime.operators.schema.common.event that return TableId

Modifier and Type	Method	Description
TableId	GetEvolvedSchemaRequest.getTableId()
TableId	GetOriginalSchemaRequest.getTableId()

Methods in org.apache.flink.cdc.runtime.operators.schema.common.event with parameters of type TableId

Modifier and Type	Method	Description
static GetEvolvedSchemaRequest	GetEvolvedSchemaRequest.ofLatestSchema(TableId tableId)
static GetOriginalSchemaRequest	GetOriginalSchemaRequest.ofLatestSchema(TableId tableId)

Constructors in org.apache.flink.cdc.runtime.operators.schema.common.event with parameters of type TableId

Constructor	Description
GetEvolvedSchemaRequest(TableId tableId, int schemaVersion)
GetOriginalSchemaRequest(TableId tableId, int schemaVersion)

Uses of TableId in org.apache.flink.cdc.runtime.operators.schema.distributed

Methods in org.apache.flink.cdc.runtime.operators.schema.distributed with parameters of type TableId

Modifier and Type	Method	Description
void	SchemaCoordinator.emplaceOriginalSchema(TableId tableId, Integer subTaskId, Schema schema)

Uses of TableId in org.apache.flink.cdc.runtime.operators.schema.distributed.event

Methods in org.apache.flink.cdc.runtime.operators.schema.distributed.event that return types with arguments of type TableId

Modifier and Type	Method	Description
Map<TableId,Schema>	SchemaChangeResponse.getEvolvedSchemas()

Constructor parameters in org.apache.flink.cdc.runtime.operators.schema.distributed.event with type arguments of type TableId

Constructor	Description
SchemaChangeResponse(Map<TableId,Schema> evolvedSchemas, List<SchemaChangeEvent> evolvedSchemaChangeEvents)

Uses of TableId in org.apache.flink.cdc.runtime.operators.schema.regular

Methods in org.apache.flink.cdc.runtime.operators.schema.regular with parameters of type TableId

Modifier and Type	Method	Description
void	SchemaOperator.registerInitialSchema(TableId tableId, Schema schema)

Uses of TableId in org.apache.flink.cdc.runtime.operators.schema.regular.event

Methods in org.apache.flink.cdc.runtime.operators.schema.regular.event that return TableId

Modifier and Type	Method	Description
TableId	SchemaChangeRequest.getTableId()

Methods in org.apache.flink.cdc.runtime.operators.schema.regular.event that return types with arguments of type TableId

Modifier and Type	Method	Description
Map<TableId,Schema>	SchemaChangeResponse.getEvolvedSchemas()

Constructors in org.apache.flink.cdc.runtime.operators.schema.regular.event with parameters of type TableId

Constructor	Description
SchemaChangeRequest(TableId tableId, SchemaChangeEvent schemaChangeEvent, int subTaskId)

Constructor parameters in org.apache.flink.cdc.runtime.operators.schema.regular.event with type arguments of type TableId

Constructor	Description
SchemaChangeResponse(List<SchemaChangeEvent> appliedSchemaChangeEvents, Map<TableId,Schema> evolvedSchemas)

Uses of TableId in org.apache.flink.cdc.runtime.operators.sink

Methods in org.apache.flink.cdc.runtime.operators.sink with parameters of type TableId

Modifier and Type	Method	Description
Optional<Schema>	SchemaEvolutionClient.getLatestEvolvedSchema(TableId tableId)
Optional<Schema>	SchemaEvolutionClient.getLatestOriginalSchema(TableId tableId)

Uses of TableId in org.apache.flink.cdc.runtime.operators.transform

Fields in org.apache.flink.cdc.runtime.operators.transform declared as TableId

Modifier and Type	Field	Description
static TableId	PreTransformChangeInfo.Serializer.MAGIC_TABLE_ID	Used to distinguish with the state which CURRENT_VERSION was not written.

Methods in org.apache.flink.cdc.runtime.operators.transform that return TableId

Modifier and Type	Method	Description
TableId	PostTransformChangeInfo.getTableId()
TableId	PreTransformChangeInfo.getTableId()

Methods in org.apache.flink.cdc.runtime.operators.transform with parameters of type TableId

Modifier and Type	Method	Description
static PostTransformChangeInfo	PostTransformChangeInfo.of(TableId tableId, Schema preTransformedSchema, Schema postTransformedSchema)
static PreTransformChangeInfo	PreTransformChangeInfo.of(TableId tableId, Schema sourceSchema, Schema preTransformedSchema)
void	PreTransformOperator.processProjectionTransform(TableId tableId, Schema tableSchema, LinkedHashSet<Column> referencedColumnsSet, PreTransformer transform)

Constructors in org.apache.flink.cdc.runtime.operators.transform with parameters of type TableId

Constructor	Description
PreTransformChangeInfo(TableId tableId, Schema sourceSchema, Schema preTransformedSchema, RecordData.FieldGetter[] sourceFieldGettersMap, BinaryRecordDataGenerator preTransformedRecordDataGenerator)

Uses of TableId in org.apache.flink.cdc.runtime.operators.transform.exceptions

Constructors in org.apache.flink.cdc.runtime.operators.transform.exceptions with parameters of type TableId

Constructor	Description
TransformException(String command, Event event, TableId tableId, Schema schemaBefore, Schema schemaAfter, Throwable cause)

Uses of TableId in org.apache.flink.cdc.runtime.serializer

Methods in org.apache.flink.cdc.runtime.serializer that return TableId

Modifier and Type	Method	Description
TableId	TableIdSerializer.copy(TableId from)
TableId	TableIdSerializer.copy(TableId from, TableId reuse)
TableId	TableIdSerializer.createInstance()
TableId	TableIdSerializer.deserialize(TableId reuse, org.apache.flink.core.memory.DataInputView source)
TableId	TableIdSerializer.deserialize(org.apache.flink.core.memory.DataInputView source)

Methods in org.apache.flink.cdc.runtime.serializer that return types with arguments of type TableId

Modifier and Type	Method	Description
org.apache.flink.api.common.typeutils.TypeSerializer<TableId>	TableIdSerializer.duplicate()
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot<TableId>	TableIdSerializer.snapshotConfiguration()

Methods in org.apache.flink.cdc.runtime.serializer with parameters of type TableId

Modifier and Type	Method	Description
TableId	TableIdSerializer.copy(TableId from)
TableId	TableIdSerializer.copy(TableId from, TableId reuse)
TableId	TableIdSerializer.deserialize(TableId reuse, org.apache.flink.core.memory.DataInputView source)
void	TableIdSerializer.serialize(TableId record, org.apache.flink.core.memory.DataOutputView target)