This is an automated email from the ASF dual-hosted git repository.
yx9o 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 5be90e34ea5 Rename StorageUnitDefinitionProcessor.getRuleClass()
(#30036)
5be90e34ea5 is described below
commit 5be90e34ea5c2ef49a3317b479973d444720eb06
Author: Liang Zhang <[email protected]>
AuthorDate: Wed Feb 7 12:24:42 2024 +0800
Rename StorageUnitDefinitionProcessor.getRuleClass() (#30036)
---
.../handler/update/StorageUnitBroadcastDefinitionProcessor.java | 2 +-
.../type/update/rdl/resource/StorageUnitDefinitionProcessor.java | 6 +++---
.../handler/update/StorageUnitSingleDefinitionProcessor.java | 2 +-
.../handler/distsql/rdl/resource/UnregisterStorageUnitExecutor.java | 2 +-
.../rdl/resource/fixture/FixtureStorageUnitDefinitionProcessor.java | 2 +-
5 files changed, 7 insertions(+), 7 deletions(-)
diff --git
a/features/broadcast/distsql/handler/src/main/java/org/apache/shardingsphere/broadcast/distsql/handler/update/StorageUnitBroadcastDefinitionProcessor.java
b/features/broadcast/distsql/handler/src/main/java/org/apache/shardingsphere/broadcast/distsql/handler/update/StorageUnitBroadcastDefinitionProcessor.java
index 41f4c46a0b2..a65e43cee31 100644
---
a/features/broadcast/distsql/handler/src/main/java/org/apache/shardingsphere/broadcast/distsql/handler/update/StorageUnitBroadcastDefinitionProcessor.java
+++
b/features/broadcast/distsql/handler/src/main/java/org/apache/shardingsphere/broadcast/distsql/handler/update/StorageUnitBroadcastDefinitionProcessor.java
@@ -32,7 +32,7 @@ public final class StorageUnitBroadcastDefinitionProcessor
implements StorageUni
}
@Override
- public Class<BroadcastRule> getRule() {
+ public Class<BroadcastRule> getRuleClass() {
return BroadcastRule.class;
}
}
diff --git
a/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/type/update/rdl/resource/StorageUnitDefinitionProcessor.java
b/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/type/update/rdl/resource/StorageUnitDefinitionProcessor.java
index 8266e3c37e8..ee362e88f98 100644
---
a/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/type/update/rdl/resource/StorageUnitDefinitionProcessor.java
+++
b/infra/distsql-handler/src/main/java/org/apache/shardingsphere/distsql/handler/type/update/rdl/resource/StorageUnitDefinitionProcessor.java
@@ -38,9 +38,9 @@ public interface StorageUnitDefinitionProcessor<T extends
ShardingSphereRule> {
boolean ignoreUsageCheckOnUnregister(UnregisterStorageUnitStatement
sqlStatement);
/**
- * Get rule.
+ * Get rule class.
*
- * @return rule
+ * @return rule class
*/
- Class<T> getRule();
+ Class<T> getRuleClass();
}
diff --git
a/kernel/single/distsql/handler/src/main/java/org/apache/shardingsphere/single/distsql/handler/update/StorageUnitSingleDefinitionProcessor.java
b/kernel/single/distsql/handler/src/main/java/org/apache/shardingsphere/single/distsql/handler/update/StorageUnitSingleDefinitionProcessor.java
index ff336704176..bb1fcec8d50 100644
---
a/kernel/single/distsql/handler/src/main/java/org/apache/shardingsphere/single/distsql/handler/update/StorageUnitSingleDefinitionProcessor.java
+++
b/kernel/single/distsql/handler/src/main/java/org/apache/shardingsphere/single/distsql/handler/update/StorageUnitSingleDefinitionProcessor.java
@@ -32,7 +32,7 @@ public final class StorageUnitSingleDefinitionProcessor
implements StorageUnitDe
}
@Override
- public Class<SingleRule> getRule() {
+ public Class<SingleRule> getRuleClass() {
return SingleRule.class;
}
}
diff --git
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/UnregisterStorageUnitExecutor.java
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/UnregisterStorageUnitExecutor.java
index c280285e230..399883600c6 100644
---
a/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/UnregisterStorageUnitExecutor.java
+++
b/proxy/backend/core/src/main/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/UnregisterStorageUnitExecutor.java
@@ -89,7 +89,7 @@ public final class UnregisterStorageUnitExecutor implements
DistSQLUpdateExecuto
Collection<Class<ShardingSphereRule>> result = new LinkedList<>();
for (StorageUnitDefinitionProcessor each :
ShardingSphereServiceLoader.getServiceInstances(StorageUnitDefinitionProcessor.class))
{
if (each.ignoreUsageCheckOnUnregister(sqlStatement)) {
- result.add(each.getRule());
+ result.add(each.getRuleClass());
}
}
return result;
diff --git
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/fixture/FixtureStorageUnitDefinitionProcessor.java
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/fixture/FixtureStorageUnitDefinitionProcessor.java
index cf144586573..aaa7095e534 100644
---
a/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/fixture/FixtureStorageUnitDefinitionProcessor.java
+++
b/proxy/backend/core/src/test/java/org/apache/shardingsphere/proxy/backend/handler/distsql/rdl/resource/fixture/FixtureStorageUnitDefinitionProcessor.java
@@ -28,7 +28,7 @@ public final class FixtureStorageUnitDefinitionProcessor
implements StorageUnitD
}
@Override
- public Class<FixtureUnregisterStorageUnitRule> getRule() {
+ public Class<FixtureUnregisterStorageUnitRule> getRuleClass() {
return FixtureUnregisterStorageUnitRule.class;
}
}