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));