Uses of Class
org.apache.flink.cdc.common.route.TableIdRouter

Packages that use TableIdRouter

Package	Description
org.apache.flink.cdc.runtime.operators.schema.common

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

Fields in org.apache.flink.cdc.runtime.operators.schema.common declared as TableIdRouter

Modifier and Type	Field	Description
protected TableIdRouter	SchemaRegistry.router

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

Modifier and Type	Method	Description
static List<CreateTableEvent>	SchemaDerivator.deduceMergedCreateTableEvent(TableIdRouter router, List<CreateTableEvent> createTableEvents)	Deduce merged CreateTableEvent.
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, 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.