Add comments for tableIdMappingCache

apache · Jul 8, 2024 · 01d4cce · 01d4cce
1 parent 6790741
commit 01d4cce
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...c-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java b/...c-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/SchemaOperator.java
@@ -101,6 +101,11 @@ public class SchemaOperator extends AbstractStreamOperator<Event>
     private transient TaskOperatorEventGateway toCoordinator;
     private transient SchemaEvolutionClient schemaEvolutionClient;
     private transient LoadingCache<TableId, Schema> cachedSchemas;
+
+    /**
+     * Storing mapping relations between upstream tableId (source table) mapping to downstream
+     * tableIds (sink tables).
+     */
     private transient LoadingCache<TableId, List<TableId>> tableIdMappingCache;
 
     private final long rpcTimeOutInMillis;