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 <[email protected]>
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);
