This is an automated email from the ASF dual-hosted git repository. tuichenchuxin pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
from bd2977dce43 Remove ResourceHeldRuleAttribute (#30520) add 37da1d36b4c Remove old meta data structure code (#30469) No new revisions were added by this update. Summary of changes: .../impl/proxy/ProxyStateExporterTest.java | 2 +- .../PrometheusPluginLifecycleServiceTest.java | 2 +- ...dcastDataNodeRuleConfigurationSwapperTest.java} | 2 +- ...cryptDataNodeRuleConfigurationSwapperTest.java} | 2 +- ...lMaskDataNodeRuleConfigurationSwapperTest.java} | 2 +- ...ttingDataNodeRuleConfigurationSwapperTest.java} | 2 +- ...hadowDataNodeRuleConfigurationSwapperTest.java} | 2 +- ...rdingDataNodeRuleConfigurationSwapperTest.java} | 2 +- .../swapper/YamlDataNodeConfigurationSwapper.java | 3 +- ...orityDataNodeRuleConfigurationSwapperTest.java} | 3 +- ...ClockDataNodeRuleConfigurationSwapperTest.java} | 3 +- ...ggingDataNodeRuleConfigurationSwapperTest.java} | 3 +- .../metadata/factory/InternalMetaDataFactory.java | 5 +- .../factory/NewInternalMetaDataFactory.java | 86 ---- .../persist/MetaDataBasedPersistService.java | 1 - .../metadata/persist/MetaDataPersistService.java | 29 +- .../persist/NewMetaDataPersistService.java | 130 ------ .../persist/node/DatabaseMetaDataNode.java | 501 ++++++++++++++++----- .../metadata/persist/node/GlobalNode.java | 85 +++- .../persist/node/NewDatabaseMetaDataNode.java | 498 -------------------- .../metadata/persist/node/NewGlobalNode.java | 124 ----- .../datasource/DataSourceNodePersistService.java | 86 ++-- .../datasource/DataSourceUnitPersistService.java | 86 ++-- .../NewDataSourceNodePersistService.java | 121 ----- .../NewDataSourceUnitPersistService.java | 121 ----- .../database/rule/DatabaseRulePersistService.java | 108 ++++- .../rule/NewDatabaseRulePersistService.java | 136 ------ .../config/global/GlobalRulePersistService.java | 72 ++- .../config/global/NewGlobalRulePersistService.java | 122 ----- .../config/global/NewPropertiesPersistService.java | 76 ---- .../config/global/PropertiesPersistService.java | 29 +- .../database/DatabaseMetaDataPersistService.java | 13 +- .../NewDatabaseMetaDataPersistService.java | 170 ------- .../schema/NewTableMetaDataPersistService.java | 112 ----- .../schema/NewViewMetaDataPersistService.java | 112 ----- .../schema/TableMetaDataPersistService.java | 54 ++- .../service/schema/ViewMetaDataPersistService.java | 56 ++- .../version/MetaDataVersionPersistService.java | 4 +- .../persist/node/DatabaseMetaDataNodeTest.java | 160 ++++--- .../metadata/persist/node/GlobalNodeTest.java | 28 +- .../persist/node/NewDatabaseMetaDataNodeTest.java | 195 -------- .../metadata/persist/node/NewGlobalNodeTest.java | 57 --- .../DatabaseMetaDataPersistServiceTest.java | 141 ------ .../service/MetaDataVersionPersistServiceTest.java | 48 -- .../database/DataSourceUnitPersistServiceTest.java | 100 ---- .../database/DatabaseRulePersistServiceTest.java | 65 --- .../global/GlobalRulePersistServiceTest.java | 65 --- .../global/PropertiesPersistServiceTest.java | 47 -- .../schema/TableMetaDataPersistServiceTest.java | 77 ---- .../schema/ViewMetaDataPersistServiceTest.java | 77 ---- .../test/resources/yaml/persist/data-source.yaml | 9 - ...ingleDataNodeRuleConfigurationSwapperTest.java} | 3 +- ...ationDataNodeRuleConfigurationSwapperTest.java} | 3 +- ...arserDataNodeRuleConfigurationSwapperTest.java} | 3 +- ...latorDataNodeRuleConfigurationSwapperTest.java} | 3 +- ...afficDataNodeRuleConfigurationSwapperTest.java} | 3 +- ...ctionDataNodeRuleConfigurationSwapperTest.java} | 3 +- .../mode/manager/ContextManager.java | 2 +- .../context/ConfigurationContextManager.java | 35 +- .../manager/switcher/NewResourceSwitchManager.java | 139 ------ .../manager/switcher/ResourceSwitchManager.java | 181 +++----- .../mode/metadata/MetaDataContextsFactory.java | 7 +- .../mode/metadata/NewMetaDataContextsFactory.java | 172 ------- .../mode/manager/ContextManagerTest.java | 13 - .../switcher/ResourceSwitchManagerTest.java | 106 ----- .../cluster/ClusterContextManagerBuilder.java | 6 +- .../manager/cluster/ClusterModeContextManager.java | 67 ++- .../cluster/NewClusterContextManagerBuilder.java | 99 ---- .../cluster/NewClusterModeContextManager.java | 175 ------- .../cluster/coordinator/NewRegistryCenter.java | 129 ------ .../cluster/coordinator/RegistryCenter.java | 2 +- .../coordinator/registry/GovernanceWatcher.java | 2 +- .../registry/GovernanceWatcherFactory.java | 2 +- .../coordinator/registry/NewGovernanceWatcher.java | 58 --- .../registry/NewGovernanceWatcherFactory.java | 60 --- .../config/watcher/GlobalRuleChangedWatcher.java | 32 +- .../watcher/NewGlobalRuleChangedWatcher.java | 56 --- .../watcher/NewPropertiesChangedWatcher.java | 55 --- .../config/watcher/PropertiesChangedWatcher.java | 20 +- .../data/ShardingSphereDataChangedWatcher.java | 3 +- .../metadata/watcher/MetaDataChangedWatcher.java | 203 ++++----- .../watcher/NewMetaDataChangedWatcher.java | 170 ------- .../NewProcessListChangedSubscriber.java | 115 ----- .../subscriber/ProcessListChangedSubscriber.java | 3 +- .../watcher/ClusterStateChangedWatcher.java | 3 +- .../subscriber/ComputeNodeStatusSubscriber.java | 3 +- .../subscriber/NewComputeNodeStatusSubscriber.java | 69 --- .../watcher/ComputeNodeStateChangedWatcher.java | 3 +- .../watcher/StorageNodeStateChangedWatcher.java | 3 +- .../generator/ClusterWorkerIdGenerator.java | 2 +- .../generator/NewClusterWorkerIdGenerator.java | 95 ---- .../subscriber/ConfigurationChangedSubscriber.java | 130 +++--- .../subscriber/ContextManagerSubscriberFacade.java | 2 +- .../NewConfigurationChangedSubscriber.java | 136 ------ .../NewContextManagerSubscriberFacade.java | 38 -- .../NewResourceMetaDataChangedSubscriber.java | 138 ------ .../subscriber/NewStateChangedSubscriber.java | 144 ------ .../ResourceMetaDataChangedSubscriber.java | 59 ++- .../subscriber/StateChangedSubscriber.java | 1 + ...rYamlPersistRepositoryConfigurationSwapper.java | 4 +- ...rYamlPersistRepositoryConfigurationSwapper.java | 50 -- ....mode.YamlPersistRepositoryConfigurationSwapper | 1 - ...ardingsphere.mode.manager.ContextManagerBuilder | 1 - ....cluster.coordinator.registry.GovernanceWatcher | 6 +- ...uster.coordinator.registry.NewGovernanceWatcher | 24 - .../cluster/ClusterModeContextManagerTest.java | 479 -------------------- .../watcher/GlobalRuleChangedWatcherTest.java | 50 -- .../watcher/PropertiesChangedWatcherTest.java | 47 -- .../watcher/MetaDataChangedWatcherTest.java | 139 ------ .../ConfigurationChangedSubscriberTest.java | 175 ------- .../ResourceMetaDataChangedSubscriberTest.java | 22 - .../NewStandaloneContextManagerBuilder.java | 83 ---- .../NewStandaloneModeContextManager.java | 333 -------------- .../StandaloneContextManagerBuilder.java | 15 +- .../standalone/StandaloneModeContextManager.java | 81 +++- ...eYamlPersistRepositoryConfigurationSwapper.java | 47 -- ...eYamlPersistRepositoryConfigurationSwapper.java | 4 +- ....mode.YamlPersistRepositoryConfigurationSwapper | 1 - ...ardingsphere.mode.manager.ContextManagerBuilder | 1 - .../StandaloneContextManagerBuilderTest.java | 66 --- .../context/BackendExecutorContextTest.java | 2 +- .../executor/ShowCurrentUserExecutorTest.java | 2 +- .../PostgreSQLAuthenticationEngineTest.java | 2 +- .../PostgreSQLCommandExecuteEngineTest.java | 2 +- .../empty_rules/mysql/show_storage_units.xml | 36 +- .../pipeline/core/util/PipelineContextUtils.java | 3 +- 126 files changed, 1465 insertions(+), 7001 deletions(-) rename features/broadcast/core/src/test/java/org/apache/shardingsphere/broadcast/yaml/swapper/{NewYamlBroadcastRuleConfigurationSwapperTest.java => YamlBroadcastDataNodeRuleConfigurationSwapperTest.java} (98%) rename features/encrypt/core/src/test/java/org/apache/shardingsphere/encrypt/yaml/swapper/{NewYamlEncryptRuleConfigurationSwapperTest.java => YamlEncryptDataNodeRuleConfigurationSwapperTest.java} (98%) rename features/mask/core/src/test/java/org/apache/shardingsphere/mask/yaml/swapper/{NewYamlMaskRuleConfigurationSwapperTest.java => YamlMaskDataNodeRuleConfigurationSwapperTest.java} (98%) rename features/readwrite-splitting/core/src/test/java/org/apache/shardingsphere/readwritesplitting/yaml/swapper/{NewYamlReadwriteSplittingRuleConfigurationSwapperTest.java => YamlReadwriteSplittingDataNodeRuleConfigurationSwapperTest.java} (98%) rename features/shadow/core/src/test/java/org/apache/shardingsphere/shadow/yaml/swapper/{NewYamlShadowRuleConfigurationSwapperTest.java => YamlShadowDataNodeRuleConfigurationSwapperTest.java} (99%) rename features/sharding/core/src/test/java/org/apache/shardingsphere/sharding/yaml/swapper/{NewYamlShardingRuleConfigurationSwapperTest.java => YamlShardingDataNodeRuleConfigurationSwapperTest.java} (99%) rename kernel/authority/core/src/test/java/org/apache/shardingsphere/authority/yaml/swapper/{NewYamlAuthorityRuleConfigurationSwapperTest.java => YamlAuthorityDataNodeRuleConfigurationSwapperTest.java} (94%) rename kernel/global-clock/core/src/test/java/org/apache/shardingsphere/globalclock/core/yaml/swapper/{NewYamlGlobalClockRuleConfigurationSwapperTest.java => YamlGlobalClockDataNodeRuleConfigurationSwapperTest.java} (90%) rename kernel/logging/core/src/test/java/org/apache/shardingsphere/logging/yaml/swapper/{NewYamlLoggingRuleConfigurationSwapperTest.java => YamlLoggingDataNodeRuleConfigurationSwapperTest.java} (89%) delete mode 100644 kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/factory/NewInternalMetaDataFactory.java delete mode 100644 kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/NewMetaDataPersistService.java delete mode 100644 kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/node/NewDatabaseMetaDataNode.java delete mode 100644 kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/node/NewGlobalNode.java delete mode 100644 kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/config/database/datasource/NewDataSourceNodePersistService.java delete mode 100644 kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/config/database/datasource/NewDataSourceUnitPersistService.java delete mode 100644 kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/config/database/rule/NewDatabaseRulePersistService.java delete mode 100644 kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/config/global/NewGlobalRulePersistService.java delete mode 100644 kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/config/global/NewPropertiesPersistService.java delete mode 100644 kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/database/NewDatabaseMetaDataPersistService.java delete mode 100644 kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/schema/NewTableMetaDataPersistService.java delete mode 100644 kernel/metadata/core/src/main/java/org/apache/shardingsphere/metadata/persist/service/schema/NewViewMetaDataPersistService.java delete mode 100644 kernel/metadata/core/src/test/java/org/apache/shardingsphere/metadata/persist/node/NewDatabaseMetaDataNodeTest.java delete mode 100644 kernel/metadata/core/src/test/java/org/apache/shardingsphere/metadata/persist/node/NewGlobalNodeTest.java delete mode 100644 kernel/metadata/core/src/test/java/org/apache/shardingsphere/metadata/persist/service/DatabaseMetaDataPersistServiceTest.java delete mode 100644 kernel/metadata/core/src/test/java/org/apache/shardingsphere/metadata/persist/service/MetaDataVersionPersistServiceTest.java delete mode 100644 kernel/metadata/core/src/test/java/org/apache/shardingsphere/metadata/persist/service/config/database/DataSourceUnitPersistServiceTest.java delete mode 100644 kernel/metadata/core/src/test/java/org/apache/shardingsphere/metadata/persist/service/config/database/DatabaseRulePersistServiceTest.java delete mode 100644 kernel/metadata/core/src/test/java/org/apache/shardingsphere/metadata/persist/service/config/global/GlobalRulePersistServiceTest.java delete mode 100644 kernel/metadata/core/src/test/java/org/apache/shardingsphere/metadata/persist/service/config/global/PropertiesPersistServiceTest.java delete mode 100644 kernel/metadata/core/src/test/java/org/apache/shardingsphere/metadata/persist/service/schema/TableMetaDataPersistServiceTest.java delete mode 100644 kernel/metadata/core/src/test/java/org/apache/shardingsphere/metadata/persist/service/schema/ViewMetaDataPersistServiceTest.java rename kernel/single/core/src/test/java/org/apache/shardingsphere/single/yaml/config/swapper/{NewYamlSingleRuleConfigurationSwapperTest.java => YamlSingleDataNodeRuleConfigurationSwapperTest.java} (89%) rename kernel/sql-federation/core/src/test/java/org/apache/shardingsphere/sqlfederation/yaml/swapper/{NewYamlSQLFederationRuleConfigurationSwapperTest.java => YamlSQLFederationDataNodeRuleConfigurationSwapperTest.java} (89%) rename kernel/sql-parser/core/src/test/java/org/apache/shardingsphere/parser/yaml/swapper/{NewYamlSQLParserRuleConfigurationSwapperTest.java => YamlSQLParserDataNodeRuleConfigurationSwapperTest.java} (90%) rename kernel/sql-translator/core/src/test/java/org/apache/shardingsphere/sqltranslator/yaml/swapper/{NewYamlSQLTranslatorRuleConfigurationSwapperTest.java => YamlSQLTranslatorDataNodeRuleConfigurationSwapperTest.java} (89%) rename kernel/traffic/core/src/test/java/org/apache/shardingsphere/traffic/yaml/swapper/{NewYamlTrafficRuleConfigurationSwapperTest.java => YamlTrafficDataNodeRuleConfigurationSwapperTest.java} (89%) rename kernel/transaction/core/src/test/java/org/apache/shardingsphere/transaction/yaml/swapper/{NewYamlTransactionRuleConfigurationSwapperTest.java => YamlTransactionDataNodeRuleConfigurationSwapperTest.java} (90%) delete mode 100644 mode/core/src/main/java/org/apache/shardingsphere/mode/manager/switcher/NewResourceSwitchManager.java delete mode 100644 mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/NewMetaDataContextsFactory.java delete mode 100644 mode/core/src/test/java/org/apache/shardingsphere/mode/manager/switcher/ResourceSwitchManagerTest.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/NewClusterContextManagerBuilder.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/NewClusterModeContextManager.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/NewRegistryCenter.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/NewGovernanceWatcher.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/NewGovernanceWatcherFactory.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/config/watcher/NewGlobalRuleChangedWatcher.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/config/watcher/NewPropertiesChangedWatcher.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/metadata/watcher/NewMetaDataChangedWatcher.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/process/subscriber/NewProcessListChangedSubscriber.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/status/compute/subscriber/NewComputeNodeStatusSubscriber.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/workerid/generator/NewClusterWorkerIdGenerator.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/NewConfigurationChangedSubscriber.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/NewContextManagerSubscriberFacade.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/NewResourceMetaDataChangedSubscriber.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/NewStateChangedSubscriber.java delete mode 100644 mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/yaml/NewClusterYamlPersistRepositoryConfigurationSwapper.java delete mode 100644 mode/type/cluster/core/src/main/resources/META-INF/services/org.apache.shardingsphere.mode.manager.cluster.coordinator.registry.NewGovernanceWatcher delete mode 100644 mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/ClusterModeContextManagerTest.java delete mode 100644 mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/config/watcher/GlobalRuleChangedWatcherTest.java delete mode 100644 mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/config/watcher/PropertiesChangedWatcherTest.java delete mode 100644 mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/registry/metadata/watcher/MetaDataChangedWatcherTest.java delete mode 100644 mode/type/cluster/core/src/test/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/subscriber/ConfigurationChangedSubscriberTest.java delete mode 100644 mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/NewStandaloneContextManagerBuilder.java delete mode 100644 mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/NewStandaloneModeContextManager.java delete mode 100644 mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/yaml/NewStandaloneYamlPersistRepositoryConfigurationSwapper.java delete mode 100644 mode/type/standalone/core/src/test/java/org/apache/shardingsphere/mode/manager/standalone/StandaloneContextManagerBuilderTest.java