Rename DumperCommonContext

apache · Nov 3, 2023 · a47c1bc · a47c1bc
1 parent ef2647e
commit a47c1bc
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 11 deletions.
diff --git a/...api/context/ingest/BaseDumperContext.java → ...i/context/ingest/DumperCommonContext.java b/...api/context/ingest/BaseDumperContext.java → ...i/context/ingest/DumperCommonContext.java
@@ -39,7 +39,7 @@
 @Getter
 @Setter
 @ToString(exclude = {"dataSourceConfig", "tableNameSchemaNameMapping"})
-public abstract class BaseDumperContext {
+public abstract class DumperCommonContext {
 
     private String dataSourceName;
 

diff --git a/.../org/apache/shardingsphere/data/pipeline/api/context/ingest/IncrementalDumperContext.java b/.../org/apache/shardingsphere/data/pipeline/api/context/ingest/IncrementalDumperContext.java
@@ -27,7 +27,7 @@
 @Getter
 @Setter
 @ToString(callSuper = true)
-public class IncrementalDumperContext extends BaseDumperContext {
+public final class IncrementalDumperContext extends DumperCommonContext {
 
     private String jobId;
 

diff --git a/...va/org/apache/shardingsphere/data/pipeline/api/context/ingest/InventoryDumperContext.java b/...va/org/apache/shardingsphere/data/pipeline/api/context/ingest/InventoryDumperContext.java
@@ -31,7 +31,7 @@
 @Getter
 @Setter
 @ToString(callSuper = true)
-public final class InventoryDumperContext extends BaseDumperContext {
+public final class InventoryDumperContext extends DumperCommonContext {
 
     private String actualTableName;
 
@@ -51,7 +51,7 @@ public final class InventoryDumperContext extends BaseDumperContext {
 
     private JobRateLimitAlgorithm rateLimitAlgorithm;
 
-    public InventoryDumperContext(final BaseDumperContext dumperContext) {
+    public InventoryDumperContext(final DumperCommonContext dumperContext) {
         setDataSourceName(dumperContext.getDataSourceName());
         setDataSourceConfig(dumperContext.getDataSourceConfig());
         setTableNameMap(dumperContext.getTableNameMap());

diff --git a/...g/apache/shardingsphere/test/it/data/pipeline/core/prepare/InventoryTaskSplitterTest.java b/...g/apache/shardingsphere/test/it/data/pipeline/core/prepare/InventoryTaskSplitterTest.java
@@ -17,7 +17,7 @@
 
 package org.apache.shardingsphere.test.it.data.pipeline.core.prepare;
 
-import org.apache.shardingsphere.data.pipeline.api.context.ingest.BaseDumperContext;
+import org.apache.shardingsphere.data.pipeline.api.context.ingest.DumperCommonContext;
 import org.apache.shardingsphere.data.pipeline.api.context.ingest.InventoryDumperContext;
 import org.apache.shardingsphere.data.pipeline.api.metadata.model.PipelineColumnMetaData;
 import org.apache.shardingsphere.data.pipeline.common.datasource.PipelineDataSourceManager;
@@ -143,7 +143,7 @@ void assertSplitInventoryDataWithoutPrimaryAndUniqueIndex() throws SQLException
         }
     }
 
-    private void initEmptyTablePrimaryEnvironment(final BaseDumperContext dumperContext) throws SQLException {
+    private void initEmptyTablePrimaryEnvironment(final DumperCommonContext dumperContext) throws SQLException {
         DataSource dataSource = dataSourceManager.getDataSource(dumperContext.getDataSourceConfig());
         try (
                 Connection connection = dataSource.getConnection();
@@ -153,7 +153,7 @@ private void initEmptyTablePrimaryEnvironment(final BaseDumperContext dumperCont
         }
     }
 
-    private void initIntPrimaryEnvironment(final BaseDumperContext dumperContext) throws SQLException {
+    private void initIntPrimaryEnvironment(final DumperCommonContext dumperContext) throws SQLException {
         DataSource dataSource = dataSourceManager.getDataSource(dumperContext.getDataSourceConfig());
         try (
                 Connection connection = dataSource.getConnection();
@@ -166,7 +166,7 @@ private void initIntPrimaryEnvironment(final BaseDumperContext dumperContext) th
         }
     }
 
-    private void initCharPrimaryEnvironment(final BaseDumperContext dumperContext) throws SQLException {
+    private void initCharPrimaryEnvironment(final DumperCommonContext dumperContext) throws SQLException {
         DataSource dataSource = dataSourceManager.getDataSource(dumperContext.getDataSourceConfig());
         try (
                 Connection connection = dataSource.getConnection();
@@ -177,7 +177,7 @@ private void initCharPrimaryEnvironment(final BaseDumperContext dumperContext) t
         }
     }
 
-    private void initUnionPrimaryEnvironment(final BaseDumperContext dumperContext) throws SQLException {
+    private void initUnionPrimaryEnvironment(final DumperCommonContext dumperContext) throws SQLException {
         DataSource dataSource = dataSourceManager.getDataSource(dumperContext.getDataSourceConfig());
         try (
                 Connection connection = dataSource.getConnection();
@@ -188,7 +188,7 @@ private void initUnionPrimaryEnvironment(final BaseDumperContext dumperContext)
         }
     }
 
-    private void initNoPrimaryEnvironment(final BaseDumperContext dumperContext) throws SQLException {
+    private void initNoPrimaryEnvironment(final DumperCommonContext dumperContext) throws SQLException {
         DataSource dataSource = dataSourceManager.getDataSource(dumperContext.getDataSourceConfig());
         try (
                 Connection connection = dataSource.getConnection();
@@ -199,7 +199,7 @@ private void initNoPrimaryEnvironment(final BaseDumperContext dumperContext) thr
         }
     }
 
-    private void initUniqueIndexOnNotNullColumnEnvironment(final BaseDumperContext dumperContext) throws SQLException {
+    private void initUniqueIndexOnNotNullColumnEnvironment(final DumperCommonContext dumperContext) throws SQLException {
         DataSource dataSource = dataSourceManager.getDataSource(dumperContext.getDataSourceConfig());
         try (
                 Connection connection = dataSource.getConnection();