From f4d413f8cd29dd13585a226bb91e0c40bdef28e9 Mon Sep 17 00:00:00 2001 From: zhangliang Date: Sat, 4 Nov 2023 21:16:03 +0800 Subject: [PATCH] Add ActualAndLogicTableNameMapper --- .../ingest/MigrationIncrementalDumperContextCreator.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/ingest/MigrationIncrementalDumperContextCreator.java b/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/ingest/MigrationIncrementalDumperContextCreator.java index 39718dead3623..659b15995eb2e 100644 --- a/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/ingest/MigrationIncrementalDumperContextCreator.java +++ b/kernel/data-pipeline/scenario/migration/src/main/java/org/apache/shardingsphere/data/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; }