From 5198656f8d3180b4959b2c2f84410b5290c99cb5 Mon Sep 17 00:00:00 2001 From: zhangliang Date: Fri, 3 Nov 2023 00:37:53 +0800 Subject: [PATCH] Rename IncrementalDumperConfiguration --- .../pipeline/api/config/ingest/BaseDumperConfiguration.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/ingest/BaseDumperConfiguration.java b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/ingest/BaseDumperConfiguration.java index 1004f464e586b..59b9ebd41fa21 100644 --- a/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/ingest/BaseDumperConfiguration.java +++ b/kernel/data-pipeline/api/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/ingest/BaseDumperConfiguration.java @@ -45,8 +45,6 @@ public abstract class BaseDumperConfiguration { private PipelineDataSourceConfiguration dataSourceConfig; - private IngestPosition position; - private Map tableNameMap; private TableNameSchemaNameMapping tableNameSchemaNameMapping; @@ -54,6 +52,8 @@ public abstract class BaseDumperConfiguration { // LinkedHashSet is required private Map> targetTableColumnsMap = new HashMap<>(); + private IngestPosition position; + /** * Get logic table name. * @@ -92,7 +92,7 @@ public String getSchemaName(final LogicTableName logicTableName) { * Get schema name. * * @param actualTableName actual table name - * @return schema name. nullable + * @return schema name, can be nullable */ public String getSchemaName(final ActualTableName actualTableName) { return tableNameSchemaNameMapping.getSchemaName(getLogicTableName(actualTableName));