This is an automated email from the ASF dual-hosted git repository.
panjuan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from 2c61cf7 fix subquery table alias bug (#14006)
add f247a82 Refactor scaling config from global scope to rule scope,
refactor context structure, refactor job worker initialization (#14190)
No new revisions were added by this update.
Summary of changes:
.../src/main/resources/server/server.yaml | 10 --
.../api/config/EncryptRuleConfiguration.java | 10 ++
.../yaml/config/YamlEncryptRuleConfiguration.java | 5 +
.../EncryptRuleConfigurationYamlSwapper.java | 11 +-
.../EncryptRuleConfigurationYamlSwapperTest.java | 17 +++
.../resources/yaml/encrypt-dataConverters.yaml | 14 ++-
.../api/config/ShardingRuleConfiguration.java | 5 +
...ector.java => ShardingRuleAlteredDetector.java} | 35 +++++-
.../yaml/config/YamlShardingRuleConfiguration.java | 5 +
.../ShardingRuleConfigurationYamlSwapper.java | 11 ++
...pipeline.spi.rulealtered.JobRuleAlteredDetector | 18 ---
...a.pipeline.spi.rulealtered.RuleAlteredDetector} | 2 +-
.../ShardingRuleConfigurationYamlSwapperTest.java | 16 +++
.../src/test/resources/yaml/sharding-rule.yaml | 14 +++
.../src/test/resources/yaml/sharding-scaling.yaml | 23 ++--
...lterShardingTableRuleStatementPreprocessor.java | 2 +
.../OnRuleAlteredActionConfiguration.java | 18 +--
.../YamlOnRuleAlteredActionConfiguration.java | 14 +--
.../YamlRuleConfigurationSwapperEngine.java | 17 ++-
...nRuleAlteredActionConfigurationYamlSwapper.java | 48 ++++++++
...eAlteredActionConfigurationYamlSwapperTest.java | 49 ++++++++
.../data/pipeline/api/PipelineJobAPI.java | 3 +-
.../config/rulealtered/WorkflowConfiguration.java | 7 +-
.../api/config/server/ServerConfiguration.java | 43 -------
.../data/pipeline/core/api/PipelineAPIFactory.java | 15 ++-
.../pipeline/core/api/impl/PipelineJobAPIImpl.java | 36 ++++--
.../yaml/ServerConfigurationYamlSwapper.java | 52 ---------
.../server/yaml/YamlServerConfiguration.java | 46 --------
.../core/execute/FinishedCheckJobExecutor.java | 7 --
.../data/pipeline/core/job/FinishedCheckJob.java | 10 +-
.../core/prepare/InventoryTaskSplitter.java | 8 +-
.../data/pipeline/core/task/IncrementalTask.java | 9 +-
.../data/pipeline/core/task/InventoryTask.java | 24 ++--
.../pipeline/core/task/PipelineTaskFactory.java | 55 ---------
.../scenario/rulealtered/RuleAlteredContext.java | 70 ++++++------
.../rulealtered/RuleAlteredJobContext.java | 3 +
.../rulealtered/RuleAlteredJobPreparer.java | 10 +-
.../RuleAlteredJobProgressDetector.java | 10 +-
.../rulealtered/RuleAlteredJobScheduler.java | 4 +-
.../scenario/rulealtered/RuleAlteredJobWorker.java | 124 ++++++++++++++++++---
...teredDetector.java => RuleAlteredDetector.java} | 31 +++++-
.../proxy/backend/context/ProxyContext.java | 10 --
.../rdl/rule/RuleDefinitionBackendHandler.java | 7 +-
.../distsql/DistSQLBackendHandlerFactoryTest.java | 8 +-
.../config/yaml/YamlProxyServerConfiguration.java | 3 -
.../proxy/initializer/BootstrapInitializer.java | 56 +++-------
.../src/main/resources/conf/config-sharding.yaml | 26 ++++-
.../src/main/resources/conf/server.yaml | 10 --
...owScalingCheckAlgorithmsQueryResultSetTest.java | 12 --
.../yaml/ServerConfigurationYamlSwapperTest.java | 77 -------------
.../api/impl/GovernanceRepositoryAPIImplTest.java | 21 +---
.../pipeline/api/impl/PipelineJobAPIImplTest.java | 30 ++---
...ureRuleAlteredJobCompletionDetectAlgorithm.java | 2 +-
.../pipeline/core/job/FinishedCheckJobTest.java | 26 +----
.../core/prepare/InventoryTaskSplitterTest.java | 11 +-
.../pipeline/core/task/IncrementalTaskTest.java | 7 +-
.../data/pipeline/core/task/InventoryTaskTest.java | 32 +++---
.../data/pipeline/core/util/ResourceUtil.java | 4 +-
.../pipeline/core/util/RuleAlteredContextUtil.java | 53 +++++++++
.../scenario/rulealtered/RuleAlteredJobTest.java | 21 +---
.../config_sharding_sphere_jdbc_source.yaml | 9 ++
.../config_sharding_sphere_jdbc_target.yaml | 9 ++
62 files changed, 707 insertions(+), 638 deletions(-)
copy
examples/example-core/config-utility/src/main/resources/META-INF/services/org.apache.shardingsphere.encrypt.spi.EncryptAlgorithm
=>
shardingsphere-features/shardingsphere-encrypt/shardingsphere-encrypt-core/src/test/resources/yaml/encrypt-dataConverters.yaml
(71%)
rename
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/main/java/org/apache/shardingsphere/sharding/schedule/{JobShardingRuleAlteredDetector.java
=> ShardingRuleAlteredDetector.java} (63%)
delete mode 100644
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.rulealtered.JobRuleAlteredDetector
copy
shardingsphere-features/{shardingsphere-db-discovery/shardingsphere-db-discovery-core/src/main/resources/META-INF/services/org.apache.shardingsphere.infra.route.SQLRouter
=>
shardingsphere-sharding/shardingsphere-sharding-core/src/main/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.rulealtered.RuleAlteredDetector}
(91%)
copy
shardingsphere-test/shardingsphere-integration-scaling-test/shardingsphere-integration-scaling-test-mysql/src/test/resources/docker/scaling/conf/server.yaml
=>
shardingsphere-features/shardingsphere-sharding/shardingsphere-sharding-core/src/test/resources/yaml/sharding-scaling.yaml
(73%)
copy
shardingsphere-kernel/shardingsphere-authority/shardingsphere-authority-api/src/main/java/org/apache/shardingsphere/authority/config/AuthorityRuleConfiguration.java
=>
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/config/rulealtered/OnRuleAlteredActionConfiguration.java
(68%)
rename
shardingsphere-mode/shardingsphere-mode-type/shardingsphere-cluster-mode/shardingsphere-cluster-mode-core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/coordinator/yaml/YamlScalingConfiguration.java
=>
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/pojo/rulealtered/YamlOnRuleAlteredActionConfiguration.java
(75%)
create mode 100644
shardingsphere-infra/shardingsphere-infra-common/src/main/java/org/apache/shardingsphere/infra/yaml/config/swapper/rulealtered/OnRuleAlteredActionConfigurationYamlSwapper.java
create mode 100644
shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/yaml/config/swapper/rulealtered/OnRuleAlteredActionConfigurationYamlSwapperTest.java
delete mode 100644
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/api/config/server/ServerConfiguration.java
delete mode 100644
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/config/server/yaml/ServerConfigurationYamlSwapper.java
delete mode 100644
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/config/server/yaml/YamlServerConfiguration.java
delete mode 100644
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/PipelineTaskFactory.java
rename
shardingsphere-kernel/shardingsphere-data-pipeline/shardingsphere-data-pipeline-core/src/main/java/org/apache/shardingsphere/data/pipeline/spi/rulealtered/{JobRuleAlteredDetector.java
=> RuleAlteredDetector.java} (61%)
delete mode 100644
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/api/config/server/yaml/ServerConfigurationYamlSwapperTest.java
create mode 100644
shardingsphere-test/shardingsphere-pipeline-test/src/test/java/org/apache/shardingsphere/data/pipeline/core/util/RuleAlteredContextUtil.java
