Add ActualAndLogicTableNameMapper

apache · Nov 4, 2023 · f4d413f · f4d413f
1 parent 13c3222
commit f4d413f
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...a/pipeline/scenario/migration/config/ingest/MigrationIncrementalDumperContextCreator.java b/...a/pipeline/scenario/migration/config/ingest/MigrationIncrementalDumperContextCreator.java
@@ -18,6 +18,7 @@
 package org.apache.shardingsphere.data.pipeline.scenario.migration.config.ingest;
 
 import lombok.RequiredArgsConstructor;
+import org.apache.shardingsphere.data.pipeline.api.ingest.dumper.context.mapper.ActualAndLogicTableNameMapper;
 import org.apache.shardingsphere.data.pipeline.api.ingest.dumper.context.mapper.TableAndSchemaNameMapper;
 import org.apache.shardingsphere.data.pipeline.api.ingest.dumper.context.IncrementalDumperContext;
 import org.apache.shardingsphere.data.pipeline.api.datasource.config.PipelineDataSourceConfiguration;
@@ -52,7 +53,7 @@ private IncrementalDumperContext buildDumperContext(final String jobId, final St
         result.setJobId(jobId);
         result.setDataSourceName(dataSourceName);
         result.setDataSourceConfig(sourceDataSource);
-        result.setTableNameMap(tableNameMap);
+        result.setTableNameMapper(new ActualAndLogicTableNameMapper(tableNameMap));
         result.setTableAndSchemaNameMapper(tableAndSchemaNameMapper);
         return result;
     }