This is an automated email from the ASF dual-hosted git repository.
menghaoran 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 f592b38af8f Refactor package of TableCoordinatorNodePath (#37643)
f592b38af8f is described below
commit f592b38af8fa4ca0441e7ec8dc039208e454de0a
Author: Haoran Meng <[email protected]>
AuthorDate: Mon Jan 5 14:18:08 2026 +0800
Refactor package of TableCoordinatorNodePath (#37643)
---
.../persist/metadata/service/TableMetaDataPersistDisabledService.java | 2 +-
.../metadata/service/TableMetaDataPersistDisabledServiceTest.java | 2 +-
.../database}/DatabaseListenerCoordinatorNodePath.java | 2 +-
.../state/coordinator/{ => table}/TableCoordinatorNodePath.java | 2 +-
.../state/coordinator/{ => table}/TableCoordinatorTypeNodePath.java | 2 +-
.../type/global/state/DatabaseListenerCoordinatorNodePathTest.java | 1 +
.../global/state/coordinator/TableCoordinatorTypeNodePathTest.java | 1 +
.../dispatch/handler/global/state/DatabaseListenerChangedHandler.java | 2 +-
.../global/state/coordinator/TableCoordinatorChangedHandler.java | 4 ++--
.../database/ClusterDatabaseListenerPersistCoordinator.java | 2 +-
10 files changed, 11 insertions(+), 9 deletions(-)
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/metadata/service/TableMetaDataPersistDisabledService.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/metadata/service/TableMetaDataPersistDisabledService.java
index 5c51704a9b5..1f71f8f2b18 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/metadata/service/TableMetaDataPersistDisabledService.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/metadata/service/TableMetaDataPersistDisabledService.java
@@ -24,7 +24,7 @@ import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
import org.apache.shardingsphere.infra.yaml.schema.swapper.YamlTableSwapper;
import
org.apache.shardingsphere.mode.node.path.engine.generator.NodePathGenerator;
import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.CoordinatorType;
-import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.TableCoordinatorTypeNodePath;
+import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.table.TableCoordinatorTypeNodePath;
import
org.apache.shardingsphere.mode.persist.service.TableMetaDataPersistService;
import org.apache.shardingsphere.mode.spi.repository.PersistRepository;
diff --git
a/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/persist/metadata/service/TableMetaDataPersistDisabledServiceTest.java
b/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/persist/metadata/service/TableMetaDataPersistDisabledServiceTest.java
index 22cae1584bb..3f9efd7ce6a 100644
---
a/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/persist/metadata/service/TableMetaDataPersistDisabledServiceTest.java
+++
b/mode/core/src/test/java/org/apache/shardingsphere/mode/metadata/persist/metadata/service/TableMetaDataPersistDisabledServiceTest.java
@@ -23,7 +23,7 @@ import org.apache.shardingsphere.infra.util.yaml.YamlEngine;
import org.apache.shardingsphere.infra.yaml.schema.swapper.YamlTableSwapper;
import
org.apache.shardingsphere.mode.node.path.engine.generator.NodePathGenerator;
import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.CoordinatorType;
-import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.TableCoordinatorTypeNodePath;
+import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.table.TableCoordinatorTypeNodePath;
import org.apache.shardingsphere.mode.spi.repository.PersistRepository;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
diff --git
a/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/DatabaseListenerCoordinatorNodePath.java
b/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/database/DatabaseListenerCoordinatorNodePath.java
similarity index 98%
rename from
mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/DatabaseListenerCoordinatorNodePath.java
rename to
mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/database/DatabaseListenerCoordinatorNodePath.java
index 42b3bdecf3b..13f66fb1627 100644
---
a/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/DatabaseListenerCoordinatorNodePath.java
+++
b/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/database/DatabaseListenerCoordinatorNodePath.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.node.path.type.global.state;
+package
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.database;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/TableCoordinatorNodePath.java
b/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/table/TableCoordinatorNodePath.java
similarity index 98%
rename from
mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/TableCoordinatorNodePath.java
rename to
mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/table/TableCoordinatorNodePath.java
index 9891d339966..e26284464b3 100644
---
a/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/TableCoordinatorNodePath.java
+++
b/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/table/TableCoordinatorNodePath.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.node.path.type.global.state.coordinator;
+package
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.table;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
diff --git
a/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/TableCoordinatorTypeNodePath.java
b/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/table/TableCoordinatorTypeNodePath.java
similarity index 98%
rename from
mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/TableCoordinatorTypeNodePath.java
rename to
mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/table/TableCoordinatorTypeNodePath.java
index 872e9586f64..8f336b8824b 100644
---
a/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/TableCoordinatorTypeNodePath.java
+++
b/mode/node/src/main/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/table/TableCoordinatorTypeNodePath.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.mode.node.path.type.global.state.coordinator;
+package
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.table;
import lombok.Getter;
import org.apache.shardingsphere.mode.node.path.NodePath;
diff --git
a/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/type/global/state/DatabaseListenerCoordinatorNodePathTest.java
b/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/type/global/state/DatabaseListenerCoordinatorNodePathTest.java
index d9cc25d1698..fdaa79df22e 100644
---
a/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/type/global/state/DatabaseListenerCoordinatorNodePathTest.java
+++
b/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/type/global/state/DatabaseListenerCoordinatorNodePathTest.java
@@ -19,6 +19,7 @@ package
org.apache.shardingsphere.mode.node.path.type.global.state;
import
org.apache.shardingsphere.mode.node.path.engine.generator.NodePathGenerator;
import
org.apache.shardingsphere.mode.node.path.engine.searcher.NodePathSearcher;
+import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.database.DatabaseListenerCoordinatorNodePath;
import org.junit.jupiter.api.Test;
import static org.hamcrest.CoreMatchers.is;
diff --git
a/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/TableCoordinatorTypeNodePathTest.java
b/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/TableCoordinatorTypeNodePathTest.java
index 50d0aceafcf..665b21c36a5 100644
---
a/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/TableCoordinatorTypeNodePathTest.java
+++
b/mode/node/src/test/java/org/apache/shardingsphere/mode/node/path/type/global/state/coordinator/TableCoordinatorTypeNodePathTest.java
@@ -19,6 +19,7 @@ package
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator;
import
org.apache.shardingsphere.mode.node.path.engine.generator.NodePathGenerator;
import
org.apache.shardingsphere.mode.node.path.engine.searcher.NodePathSearcher;
+import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.table.TableCoordinatorTypeNodePath;
import org.junit.jupiter.api.Test;
import static org.hamcrest.CoreMatchers.is;
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/state/DatabaseListenerChangedHandler.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/state/DatabaseListenerChangedHandler.java
index 5ab254b63ae..4b88a106a24 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/state/DatabaseListenerChangedHandler.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/state/DatabaseListenerChangedHandler.java
@@ -30,7 +30,7 @@ import org.apache.shardingsphere.mode.node.path.NodePath;
import
org.apache.shardingsphere.mode.node.path.engine.generator.NodePathGenerator;
import
org.apache.shardingsphere.mode.node.path.engine.searcher.NodePathSearcher;
import
org.apache.shardingsphere.mode.node.path.type.database.metadata.DatabaseMetaDataNodePath;
-import
org.apache.shardingsphere.mode.node.path.type.global.state.DatabaseListenerCoordinatorNodePath;
+import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.database.DatabaseListenerCoordinatorNodePath;
import
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
import java.util.Arrays;
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/state/coordinator/TableCoordinatorChangedHandler.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/state/coordinator/TableCoordinatorChangedHandler.java
index 1a866c88456..6b2b3659bef 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/state/coordinator/TableCoordinatorChangedHandler.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/global/state/coordinator/TableCoordinatorChangedHandler.java
@@ -33,8 +33,8 @@ import
org.apache.shardingsphere.mode.node.path.engine.searcher.NodePathPattern;
import
org.apache.shardingsphere.mode.node.path.engine.searcher.NodePathSearchCriteria;
import
org.apache.shardingsphere.mode.node.path.engine.searcher.NodePathSearcher;
import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.CoordinatorType;
-import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.TableCoordinatorNodePath;
-import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.TableCoordinatorTypeNodePath;
+import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.table.TableCoordinatorNodePath;
+import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.table.TableCoordinatorTypeNodePath;
import java.util.Collection;
import java.util.Collections;
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/coordinator/database/ClusterDatabaseListenerPersistCoordinator.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/coordinator/database/ClusterDatabaseListenerPersistCoordinator.java
index f2b017c95f7..67842baaf90 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/coordinator/database/ClusterDatabaseListenerPersistCoordinator.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/coordinator/database/ClusterDatabaseListenerPersistCoordinator.java
@@ -19,7 +19,7 @@ package
org.apache.shardingsphere.mode.manager.cluster.persist.coordinator.datab
import lombok.RequiredArgsConstructor;
import
org.apache.shardingsphere.mode.node.path.engine.generator.NodePathGenerator;
-import
org.apache.shardingsphere.mode.node.path.type.global.state.DatabaseListenerCoordinatorNodePath;
+import
org.apache.shardingsphere.mode.node.path.type.global.state.coordinator.database.DatabaseListenerCoordinatorNodePath;
import
org.apache.shardingsphere.mode.repository.cluster.ClusterPersistRepository;
/**
