You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by ji...@apache.org on 2023/04/20 06:17:24 UTC
[shardingsphere] branch master updated: Refactor RALStatement inheritance structure (#25233)
This is an automated email from the ASF dual-hosted git repository.
jianglongtao pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 637d3b80dd1 Refactor RALStatement inheritance structure (#25233)
637d3b80dd1 is described below
commit 637d3b80dd171909e26a03fe9d49c7feb548be15
Author: ChenJiaHao <Pa...@163.com>
AuthorDate: Thu Apr 20 14:17:16 2023 +0800
Refactor RALStatement inheritance structure (#25233)
---
...calingRALStatement.java => FeaturedRALStatement.java} | 8 +++-----
.../PipelineRALStatement.java} | 8 ++++----
.../QueryablePipelineRALStatement.java} | 6 +++---
.../UpdatablePipelineRALStatement.java} | 6 +++---
.../cdc/CDCRALStatement.java} | 8 ++++----
.../cdc/QueryableCDCRALStatement.java} | 8 ++++----
.../migration/MigrationRALStatement.java} | 8 ++++----
.../migration/QueryableMigrationRALStatement.java} | 8 ++++----
.../migration/UpdatableMigrationRALStatement.java} | 8 ++++----
.../ral/queryable/ShowMigrationRuleStatement.java | 4 ++--
.../AlterInventoryIncrementalRuleStatement.java | 4 ++--
.../distsql/statement/ShowStreamingListStatement.java | 4 ++--
.../distsql/statement/ShowStreamingStatusStatement.java | 4 ++--
.../distsql/statement/CheckMigrationStatement.java | 4 ++--
.../distsql/statement/CommitMigrationStatement.java | 4 ++--
.../distsql/statement/DropMigrationCheckStatement.java | 4 ++--
.../distsql/statement/MigrateTableStatement.java | 4 ++--
.../RegisterMigrationSourceStorageUnitStatement.java | 4 ++--
.../distsql/statement/RollbackMigrationStatement.java | 4 ++--
.../statement/ShowMigrationCheckAlgorithmsStatement.java | 4 ++--
.../statement/ShowMigrationCheckStatusStatement.java | 4 ++--
.../distsql/statement/ShowMigrationListStatement.java | 4 ++--
.../ShowMigrationSourceStorageUnitsStatement.java | 4 ++--
.../distsql/statement/ShowMigrationStatusStatement.java | 4 ++--
.../distsql/statement/StartMigrationCheckStatement.java | 4 ++--
.../distsql/statement/StartMigrationStatement.java | 4 ++--
.../distsql/statement/StopMigrationCheckStatement.java | 4 ++--
.../distsql/statement/StopMigrationStatement.java | 4 ++--
.../UnregisterMigrationSourceStorageUnitStatement.java | 4 ++--
.../asserts/statement/ral/RALStatementAssert.java | 16 ++++++++--------
...ert.java => QueryablePipelineRALStatementAssert.java} | 16 ++++++++--------
...ert.java => UpdatablePipelineRALStatementAssert.java} | 16 ++++++++--------
32 files changed, 97 insertions(+), 99 deletions(-)
diff --git a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/FeaturedRALStatement.java
similarity index 75%
copy from distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java
copy to distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/FeaturedRALStatement.java
index 7df59b1bb84..71c8c5c848a 100644
--- a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java
+++ b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/FeaturedRALStatement.java
@@ -15,12 +15,10 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.distsql.parser.statement.ral.scaling;
-
-import org.apache.shardingsphere.distsql.parser.statement.ral.QueryableRALStatement;
+package org.apache.shardingsphere.distsql.parser.statement.ral;
/**
- * Queryable RAL statement.
+ * Featured RAL statement.
*/
-public abstract class QueryableScalingRALStatement extends QueryableRALStatement {
+public interface FeaturedRALStatement {
}
diff --git a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/PipelineRALStatement.java
similarity index 75%
copy from distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java
copy to distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/PipelineRALStatement.java
index 7df59b1bb84..37e56929105 100644
--- a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java
+++ b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/PipelineRALStatement.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.distsql.parser.statement.ral.scaling;
+package org.apache.shardingsphere.distsql.parser.statement.ral.pipeline;
-import org.apache.shardingsphere.distsql.parser.statement.ral.QueryableRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.FeaturedRALStatement;
/**
- * Queryable RAL statement.
+ * Pipeline RAL statement.
*/
-public abstract class QueryableScalingRALStatement extends QueryableRALStatement {
+public interface PipelineRALStatement extends FeaturedRALStatement {
}
diff --git a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/QueryablePipelineRALStatement.java
similarity index 79%
copy from distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java
copy to distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/QueryablePipelineRALStatement.java
index 7df59b1bb84..8bb329fc34d 100644
--- a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java
+++ b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/QueryablePipelineRALStatement.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.distsql.parser.statement.ral.scaling;
+package org.apache.shardingsphere.distsql.parser.statement.ral.pipeline;
import org.apache.shardingsphere.distsql.parser.statement.ral.QueryableRALStatement;
/**
- * Queryable RAL statement.
+ * Queryable pipeline RAL statement.
*/
-public abstract class QueryableScalingRALStatement extends QueryableRALStatement {
+public abstract class QueryablePipelineRALStatement extends QueryableRALStatement implements PipelineRALStatement {
}
diff --git a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/UpdatableScalingRALStatement.java b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/UpdatablePipelineRALStatement.java
similarity index 79%
rename from distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/UpdatableScalingRALStatement.java
rename to distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/UpdatablePipelineRALStatement.java
index b8b2dc79a05..9789a35ed3a 100644
--- a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/UpdatableScalingRALStatement.java
+++ b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/UpdatablePipelineRALStatement.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.distsql.parser.statement.ral.scaling;
+package org.apache.shardingsphere.distsql.parser.statement.ral.pipeline;
import org.apache.shardingsphere.distsql.parser.statement.ral.UpdatableRALStatement;
/**
- * Updatable RAL statement.
+ * Updatable pipeline RAL statement.
*/
-public abstract class UpdatableScalingRALStatement extends UpdatableRALStatement {
+public abstract class UpdatablePipelineRALStatement extends UpdatableRALStatement implements PipelineRALStatement {
}
diff --git a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/cdc/CDCRALStatement.java
similarity index 75%
copy from distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java
copy to distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/cdc/CDCRALStatement.java
index 7df59b1bb84..8306641c475 100644
--- a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java
+++ b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/cdc/CDCRALStatement.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.distsql.parser.statement.ral.scaling;
+package org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.cdc;
-import org.apache.shardingsphere.distsql.parser.statement.ral.QueryableRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.PipelineRALStatement;
/**
- * Queryable RAL statement.
+ * CDC RAL statement.
*/
-public abstract class QueryableScalingRALStatement extends QueryableRALStatement {
+public interface CDCRALStatement extends PipelineRALStatement {
}
diff --git a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationRuleStatement.java b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/cdc/QueryableCDCRALStatement.java
similarity index 71%
copy from distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationRuleStatement.java
copy to distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/cdc/QueryableCDCRALStatement.java
index 427771b780f..17a0a0f85dc 100644
--- a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationRuleStatement.java
+++ b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/cdc/QueryableCDCRALStatement.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.distsql.parser.statement.ral.queryable;
+package org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.cdc;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.QueryablePipelineRALStatement;
/**
- * Show migration rule statement.
+ * Queryable CDC RAL statement.
*/
-public final class ShowMigrationRuleStatement extends QueryableScalingRALStatement {
+public abstract class QueryableCDCRALStatement extends QueryablePipelineRALStatement implements CDCRALStatement {
}
diff --git a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/migration/MigrationRALStatement.java
similarity index 74%
rename from distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java
rename to distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/migration/MigrationRALStatement.java
index 7df59b1bb84..836a5cb6cac 100644
--- a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/scaling/QueryableScalingRALStatement.java
+++ b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/migration/MigrationRALStatement.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.distsql.parser.statement.ral.scaling;
+package org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration;
-import org.apache.shardingsphere.distsql.parser.statement.ral.QueryableRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.PipelineRALStatement;
/**
- * Queryable RAL statement.
+ * Migration RAL statement.
*/
-public abstract class QueryableScalingRALStatement extends QueryableRALStatement {
+public interface MigrationRALStatement extends PipelineRALStatement {
}
diff --git a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationRuleStatement.java b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/migration/QueryableMigrationRALStatement.java
similarity index 70%
copy from distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationRuleStatement.java
copy to distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/migration/QueryableMigrationRALStatement.java
index 427771b780f..29d2badee5a 100644
--- a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationRuleStatement.java
+++ b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/migration/QueryableMigrationRALStatement.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.distsql.parser.statement.ral.queryable;
+package org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.QueryablePipelineRALStatement;
/**
- * Show migration rule statement.
+ * Queryable migration RAL statement.
*/
-public final class ShowMigrationRuleStatement extends QueryableScalingRALStatement {
+public abstract class QueryableMigrationRALStatement extends QueryablePipelineRALStatement implements MigrationRALStatement {
}
diff --git a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationRuleStatement.java b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/migration/UpdatableMigrationRALStatement.java
similarity index 70%
copy from distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationRuleStatement.java
copy to distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/migration/UpdatableMigrationRALStatement.java
index 427771b780f..cb0000fd407 100644
--- a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationRuleStatement.java
+++ b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/pipeline/migration/UpdatableMigrationRALStatement.java
@@ -15,12 +15,12 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.distsql.parser.statement.ral.queryable;
+package org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.UpdatablePipelineRALStatement;
/**
- * Show migration rule statement.
+ * Updatable migration RAL statement.
*/
-public final class ShowMigrationRuleStatement extends QueryableScalingRALStatement {
+public abstract class UpdatableMigrationRALStatement extends UpdatablePipelineRALStatement implements MigrationRALStatement {
}
diff --git a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationRuleStatement.java b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationRuleStatement.java
index 427771b780f..b1d27e3590d 100644
--- a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationRuleStatement.java
+++ b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/queryable/ShowMigrationRuleStatement.java
@@ -17,10 +17,10 @@
package org.apache.shardingsphere.distsql.parser.statement.ral.queryable;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.QueryableMigrationRALStatement;
/**
* Show migration rule statement.
*/
-public final class ShowMigrationRuleStatement extends QueryableScalingRALStatement {
+public final class ShowMigrationRuleStatement extends QueryableMigrationRALStatement {
}
diff --git a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/updatable/AlterInventoryIncrementalRuleStatement.java b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/updatable/AlterInventoryIncrementalRuleStatement.java
index a9457e957eb..0b8b6db1aed 100644
--- a/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/updatable/AlterInventoryIncrementalRuleStatement.java
+++ b/distsql/statement/src/main/java/org/apache/shardingsphere/distsql/parser/statement/ral/updatable/AlterInventoryIncrementalRuleStatement.java
@@ -20,14 +20,14 @@ package org.apache.shardingsphere.distsql.parser.statement.ral.updatable;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.distsql.parser.segment.InventoryIncrementalRuleSegment;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.UpdatableMigrationRALStatement;
/**
* Alter inventory incremental rule statement.
*/
@RequiredArgsConstructor
@Getter
-public final class AlterInventoryIncrementalRuleStatement extends UpdatableScalingRALStatement {
+public final class AlterInventoryIncrementalRuleStatement extends UpdatableMigrationRALStatement {
private final String jobTypeName;
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/cdc/distsql/statement/ShowStreamingListStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/cdc/distsql/statement/ShowStreamingListStatement.java
index 5a7edd4666e..dfc351605f3 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/cdc/distsql/statement/ShowStreamingListStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/cdc/distsql/statement/ShowStreamingListStatement.java
@@ -17,10 +17,10 @@
package org.apache.shardingsphere.cdc.distsql.statement;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.cdc.QueryableCDCRALStatement;
/**
* Show streaming list statement.
*/
-public final class ShowStreamingListStatement extends QueryableScalingRALStatement {
+public final class ShowStreamingListStatement extends QueryableCDCRALStatement {
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/cdc/distsql/statement/ShowStreamingStatusStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/cdc/distsql/statement/ShowStreamingStatusStatement.java
index 8a56b2c97ca..716cc630b00 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/cdc/distsql/statement/ShowStreamingStatusStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/cdc/distsql/statement/ShowStreamingStatusStatement.java
@@ -19,14 +19,14 @@ package org.apache.shardingsphere.cdc.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.cdc.QueryableCDCRALStatement;
/**
* Show streaming status statement.
*/
@RequiredArgsConstructor
@Getter
-public final class ShowStreamingStatusStatement extends QueryableScalingRALStatement {
+public final class ShowStreamingStatusStatement extends QueryableCDCRALStatement {
private final String jobId;
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CheckMigrationStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CheckMigrationStatement.java
index b8aa727568d..f7bef648e23 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CheckMigrationStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CheckMigrationStatement.java
@@ -20,14 +20,14 @@ package org.apache.shardingsphere.migration.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.distsql.parser.segment.AlgorithmSegment;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.UpdatableMigrationRALStatement;
/**
* Check migration statement.
*/
@RequiredArgsConstructor
@Getter
-public final class CheckMigrationStatement extends UpdatableScalingRALStatement {
+public final class CheckMigrationStatement extends UpdatableMigrationRALStatement {
private final String jobId;
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CommitMigrationStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CommitMigrationStatement.java
index 818c2c3c7a2..2fbb699f8cf 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CommitMigrationStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/CommitMigrationStatement.java
@@ -19,14 +19,14 @@ package org.apache.shardingsphere.migration.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.UpdatableMigrationRALStatement;
/**
* Commit migration statement.
*/
@RequiredArgsConstructor
@Getter
-public final class CommitMigrationStatement extends UpdatableScalingRALStatement {
+public final class CommitMigrationStatement extends UpdatableMigrationRALStatement {
private final String jobId;
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/DropMigrationCheckStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/DropMigrationCheckStatement.java
index 1e0f4dc79fc..3836741e39c 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/DropMigrationCheckStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/DropMigrationCheckStatement.java
@@ -19,14 +19,14 @@ package org.apache.shardingsphere.migration.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.UpdatableMigrationRALStatement;
/**
* Drop migration check statement.
*/
@RequiredArgsConstructor
@Getter
-public final class DropMigrationCheckStatement extends UpdatableScalingRALStatement {
+public final class DropMigrationCheckStatement extends UpdatableMigrationRALStatement {
private final String jobId;
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/MigrateTableStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/MigrateTableStatement.java
index 83b27d94aea..d08773bd9a4 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/MigrateTableStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/MigrateTableStatement.java
@@ -19,7 +19,7 @@ package org.apache.shardingsphere.migration.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.UpdatableMigrationRALStatement;
import org.apache.shardingsphere.migration.distsql.statement.pojo.SourceTargetEntry;
import java.util.List;
@@ -29,7 +29,7 @@ import java.util.List;
*/
@RequiredArgsConstructor
@Getter
-public final class MigrateTableStatement extends UpdatableScalingRALStatement {
+public final class MigrateTableStatement extends UpdatableMigrationRALStatement {
private final List<SourceTargetEntry> sourceTargetEntries;
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RegisterMigrationSourceStorageUnitStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RegisterMigrationSourceStorageUnitStatement.java
index a6ce77f1501..9761449877e 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RegisterMigrationSourceStorageUnitStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RegisterMigrationSourceStorageUnitStatement.java
@@ -20,7 +20,7 @@ package org.apache.shardingsphere.migration.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
import org.apache.shardingsphere.distsql.parser.segment.DataSourceSegment;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.UpdatableMigrationRALStatement;
import java.util.Collection;
@@ -29,7 +29,7 @@ import java.util.Collection;
*/
@RequiredArgsConstructor
@Getter
-public final class RegisterMigrationSourceStorageUnitStatement extends UpdatableScalingRALStatement {
+public final class RegisterMigrationSourceStorageUnitStatement extends UpdatableMigrationRALStatement {
private final Collection<DataSourceSegment> dataSources;
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RollbackMigrationStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RollbackMigrationStatement.java
index ac224e2a715..bdd26b57c77 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RollbackMigrationStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/RollbackMigrationStatement.java
@@ -19,14 +19,14 @@ package org.apache.shardingsphere.migration.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.UpdatableMigrationRALStatement;
/**
* Rollback migration statement.
*/
@RequiredArgsConstructor
@Getter
-public final class RollbackMigrationStatement extends UpdatableScalingRALStatement {
+public final class RollbackMigrationStatement extends UpdatableMigrationRALStatement {
private final String jobId;
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckAlgorithmsStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckAlgorithmsStatement.java
index 089e0157e01..6b802f75b76 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckAlgorithmsStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckAlgorithmsStatement.java
@@ -17,10 +17,10 @@
package org.apache.shardingsphere.migration.distsql.statement;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.QueryableMigrationRALStatement;
/**
* Show migration check algorithms statement.
*/
-public final class ShowMigrationCheckAlgorithmsStatement extends QueryableScalingRALStatement {
+public final class ShowMigrationCheckAlgorithmsStatement extends QueryableMigrationRALStatement {
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckStatusStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckStatusStatement.java
index e9b2e6932d5..6088b55fcb1 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckStatusStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationCheckStatusStatement.java
@@ -19,14 +19,14 @@ package org.apache.shardingsphere.migration.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.QueryableMigrationRALStatement;
/**
* Show migration check status statement.
*/
@RequiredArgsConstructor
@Getter
-public final class ShowMigrationCheckStatusStatement extends QueryableScalingRALStatement {
+public final class ShowMigrationCheckStatusStatement extends QueryableMigrationRALStatement {
private final String jobId;
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationListStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationListStatement.java
index 93901518a61..43c9dc5ee96 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationListStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationListStatement.java
@@ -17,10 +17,10 @@
package org.apache.shardingsphere.migration.distsql.statement;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.QueryableMigrationRALStatement;
/**
* Show migration list statement.
*/
-public final class ShowMigrationListStatement extends QueryableScalingRALStatement {
+public final class ShowMigrationListStatement extends QueryableMigrationRALStatement {
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationSourceStorageUnitsStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationSourceStorageUnitsStatement.java
index 155193537b1..d916e60a1a5 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationSourceStorageUnitsStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationSourceStorageUnitsStatement.java
@@ -17,10 +17,10 @@
package org.apache.shardingsphere.migration.distsql.statement;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.QueryableMigrationRALStatement;
/**
* Show migration source storage units statement.
*/
-public final class ShowMigrationSourceStorageUnitsStatement extends QueryableScalingRALStatement {
+public final class ShowMigrationSourceStorageUnitsStatement extends QueryableMigrationRALStatement {
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationStatusStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationStatusStatement.java
index 932a9ef82b5..d7603d12771 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationStatusStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/ShowMigrationStatusStatement.java
@@ -19,14 +19,14 @@ package org.apache.shardingsphere.migration.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.QueryableMigrationRALStatement;
/**
* Show migration status statement.
*/
@RequiredArgsConstructor
@Getter
-public final class ShowMigrationStatusStatement extends QueryableScalingRALStatement {
+public final class ShowMigrationStatusStatement extends QueryableMigrationRALStatement {
private final String jobId;
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationCheckStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationCheckStatement.java
index 527eacfc647..7a251345d34 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationCheckStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationCheckStatement.java
@@ -19,14 +19,14 @@ package org.apache.shardingsphere.migration.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.UpdatableMigrationRALStatement;
/**
* Start migration check statement.
*/
@RequiredArgsConstructor
@Getter
-public final class StartMigrationCheckStatement extends UpdatableScalingRALStatement {
+public final class StartMigrationCheckStatement extends UpdatableMigrationRALStatement {
private final String jobId;
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationStatement.java
index 7627bb2e1ac..79d11200416 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StartMigrationStatement.java
@@ -19,14 +19,14 @@ package org.apache.shardingsphere.migration.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.UpdatableMigrationRALStatement;
/**
* Start migration statement.
*/
@RequiredArgsConstructor
@Getter
-public final class StartMigrationStatement extends UpdatableScalingRALStatement {
+public final class StartMigrationStatement extends UpdatableMigrationRALStatement {
private final String jobId;
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationCheckStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationCheckStatement.java
index 3f8b5bf3332..099ed09be77 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationCheckStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationCheckStatement.java
@@ -19,14 +19,14 @@ package org.apache.shardingsphere.migration.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.UpdatableMigrationRALStatement;
/**
* Stop migration check statement.
*/
@RequiredArgsConstructor
@Getter
-public final class StopMigrationCheckStatement extends UpdatableScalingRALStatement {
+public final class StopMigrationCheckStatement extends UpdatableMigrationRALStatement {
private final String jobId;
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationStatement.java
index 39e368f157f..a52650c5407 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/StopMigrationStatement.java
@@ -19,14 +19,14 @@ package org.apache.shardingsphere.migration.distsql.statement;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.UpdatableMigrationRALStatement;
/**
* Stop migration statement.
*/
@RequiredArgsConstructor
@Getter
-public final class StopMigrationStatement extends UpdatableScalingRALStatement {
+public final class StopMigrationStatement extends UpdatableMigrationRALStatement {
private final String jobId;
}
diff --git a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/UnregisterMigrationSourceStorageUnitStatement.java b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/UnregisterMigrationSourceStorageUnitStatement.java
index 8f713c7e1ac..0964f0add3f 100644
--- a/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/UnregisterMigrationSourceStorageUnitStatement.java
+++ b/kernel/data-pipeline/distsql/statement/src/main/java/org/apache/shardingsphere/migration/distsql/statement/UnregisterMigrationSourceStorageUnitStatement.java
@@ -18,7 +18,7 @@
package org.apache.shardingsphere.migration.distsql.statement;
import lombok.Getter;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.migration.UpdatableMigrationRALStatement;
import java.util.Collection;
@@ -26,7 +26,7 @@ import java.util.Collection;
* Unregister migration source storage unit statement.
*/
@Getter
-public final class UnregisterMigrationSourceStorageUnitStatement extends UpdatableScalingRALStatement {
+public final class UnregisterMigrationSourceStorageUnitStatement extends UpdatableMigrationRALStatement {
private final Collection<String> names;
diff --git a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/RALStatementAssert.java b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/RALStatementAssert.java
index ff03772188a..48ca050b560 100644
--- a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/RALStatementAssert.java
+++ b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/RALStatementAssert.java
@@ -22,13 +22,13 @@ import lombok.NoArgsConstructor;
import org.apache.shardingsphere.distsql.parser.statement.ral.QueryableRALStatement;
import org.apache.shardingsphere.distsql.parser.statement.ral.RALStatement;
import org.apache.shardingsphere.distsql.parser.statement.ral.UpdatableRALStatement;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.QueryablePipelineRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.UpdatablePipelineRALStatement;
import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.SQLCaseAssertContext;
import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.ral.impl.QueryableRALStatementAssert;
-import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.ral.impl.migration.QueryableScalingRALStatementAssert;
+import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.ral.impl.migration.QueryablePipelineRALStatementAssert;
import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.ral.impl.UpdatableRALStatementAssert;
-import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.ral.impl.migration.UpdatableScalingRALStatementAssert;
+import org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.ral.impl.migration.UpdatablePipelineRALStatementAssert;
import org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.SQLParserTestCase;
/**
@@ -45,10 +45,10 @@ public final class RALStatementAssert {
* @param expected expected RAL statement test case
*/
public static void assertIs(final SQLCaseAssertContext assertContext, final RALStatement actual, final SQLParserTestCase expected) {
- if (actual instanceof QueryableScalingRALStatement) {
- QueryableScalingRALStatementAssert.assertIs(assertContext, (QueryableScalingRALStatement) actual, expected);
- } else if (actual instanceof UpdatableScalingRALStatement) {
- UpdatableScalingRALStatementAssert.assertIs(assertContext, (UpdatableScalingRALStatement) actual, expected);
+ if (actual instanceof QueryablePipelineRALStatement) {
+ QueryablePipelineRALStatementAssert.assertIs(assertContext, (QueryablePipelineRALStatement) actual, expected);
+ } else if (actual instanceof UpdatablePipelineRALStatement) {
+ UpdatablePipelineRALStatementAssert.assertIs(assertContext, (UpdatablePipelineRALStatement) actual, expected);
} else if (actual instanceof QueryableRALStatement) {
QueryableRALStatementAssert.assertIs(assertContext, (QueryableRALStatement) actual, expected);
} else if (actual instanceof UpdatableRALStatement) {
diff --git a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/migration/QueryableScalingRALStatementAssert.java b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/migration/QueryablePipelineRALStatementAssert.java
similarity index 89%
rename from test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/migration/QueryableScalingRALStatementAssert.java
rename to test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/migration/QueryablePipelineRALStatementAssert.java
index cc3ca370419..f99b093857a 100644
--- a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/migration/QueryableScalingRALStatementAssert.java
+++ b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/migration/QueryablePipelineRALStatementAssert.java
@@ -21,7 +21,7 @@ import lombok.AccessLevel;
import lombok.NoArgsConstructor;
import org.apache.shardingsphere.cdc.distsql.statement.ShowStreamingListStatement;
import org.apache.shardingsphere.cdc.distsql.statement.ShowStreamingStatusStatement;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.QueryableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.QueryablePipelineRALStatement;
import org.apache.shardingsphere.migration.distsql.statement.ShowMigrationCheckAlgorithmsStatement;
import org.apache.shardingsphere.migration.distsql.statement.ShowMigrationCheckStatusStatement;
import org.apache.shardingsphere.migration.distsql.statement.ShowMigrationListStatement;
@@ -38,19 +38,19 @@ import org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.s
import org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.statement.ral.migration.ShowMigrationStatusStatementTestCase;
/**
- * Queryable RAL statement assert.
+ * Queryable pipeline RAL statement assert.
*/
@NoArgsConstructor(access = AccessLevel.PRIVATE)
-public final class QueryableScalingRALStatementAssert {
+public final class QueryablePipelineRALStatementAssert {
/**
- * Assert query RAL statement is correct with expected parser result.
- *
+ * Assert query pipeline RAL statement is correct with expected parser result.
+ *
* @param assertContext assert context
- * @param actual actual queryable RAL statement
- * @param expected expected queryable RAL statement test case
+ * @param actual actual queryable pipeline RAL statement
+ * @param expected expected queryable pipeline RAL statement test case
*/
- public static void assertIs(final SQLCaseAssertContext assertContext, final QueryableScalingRALStatement actual, final SQLParserTestCase expected) {
+ public static void assertIs(final SQLCaseAssertContext assertContext, final QueryablePipelineRALStatement actual, final SQLParserTestCase expected) {
// TODO add more test case
if (actual instanceof ShowMigrationListStatement) {
ExistingAssert.assertIs(assertContext, actual, expected);
diff --git a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/migration/UpdatableScalingRALStatementAssert.java b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/migration/UpdatablePipelineRALStatementAssert.java
similarity index 93%
rename from test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/migration/UpdatableScalingRALStatementAssert.java
rename to test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/migration/UpdatablePipelineRALStatementAssert.java
index 9a2c957136b..378ffec2da2 100644
--- a/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/migration/UpdatableScalingRALStatementAssert.java
+++ b/test/it/parser/src/main/java/org/apache/shardingsphere/test/it/sql/parser/internal/asserts/statement/ral/impl/migration/UpdatablePipelineRALStatementAssert.java
@@ -19,7 +19,7 @@ package org.apache.shardingsphere.test.it.sql.parser.internal.asserts.statement.
import lombok.AccessLevel;
import lombok.NoArgsConstructor;
-import org.apache.shardingsphere.distsql.parser.statement.ral.scaling.UpdatableScalingRALStatement;
+import org.apache.shardingsphere.distsql.parser.statement.ral.pipeline.UpdatablePipelineRALStatement;
import org.apache.shardingsphere.migration.distsql.statement.CheckMigrationStatement;
import org.apache.shardingsphere.migration.distsql.statement.CommitMigrationStatement;
import org.apache.shardingsphere.migration.distsql.statement.MigrateTableStatement;
@@ -54,19 +54,19 @@ import org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.s
import org.apache.shardingsphere.test.it.sql.parser.internal.cases.parser.jaxb.statement.ral.migration.UnregisterMigrationSourceStorageUnitStatementTestCase;
/**
- * Updatable Scaling RAL statement assert.
+ * Updatable pipeline RAL statement assert.
*/
@NoArgsConstructor(access = AccessLevel.PRIVATE)
-public final class UpdatableScalingRALStatementAssert {
+public final class UpdatablePipelineRALStatementAssert {
/**
- * Assert updatable scaling RAL statement is correct with expected parser result.
- *
+ * Assert updatable pipeline RAL statement is correct with expected parser result.
+ *
* @param assertContext assert context
- * @param actual actual updatable scaling RAL statement
- * @param expected expected updatable scaling RAL statement test case
+ * @param actual actual updatable pipeline RAL statement
+ * @param expected expected updatable pipeline RAL statement test case
*/
- public static void assertIs(final SQLCaseAssertContext assertContext, final UpdatableScalingRALStatement actual, final SQLParserTestCase expected) {
+ public static void assertIs(final SQLCaseAssertContext assertContext, final UpdatablePipelineRALStatement actual, final SQLParserTestCase expected) {
// TODO add more test case
if (actual instanceof MigrateTableStatement) {
MigrateTableStatementAssert.assertIs(assertContext, (MigrateTableStatement) actual, (MigrateTableStatementTestCase) expected);