This is an automated email from the ASF dual-hosted git repository.
menghaoran pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git.
from 988f293 UUpdate mix config for YAML (#9285)
add 375885c Optimize scaling package. (#9287)
No new revisions were added by this update.
Summary of changes:
.../scaling/web/HttpServerHandler.java | 2 +-
.../scaling/web/HttpServerHandlerTest.java | 2 +-
.../scaling/core/api/RegistryRepositoryAPI.java | 2 +-
.../scaling/core/api/ScalingAPI.java | 2 +-
.../scaling/core/api/ScalingAPIFactory.java | 2 +-
.../scaling/core/api/ScalingWorker.java | 4 +-
.../core/api/impl/RegistryRepositoryAPIImpl.java | 4 +-
.../scaling/core/api/impl/ScalingAPIImpl.java | 6 +-
.../{internal => }/common/channel/AckCallback.java | 4 +-
.../{internal => }/common/channel/Channel.java | 4 +-
.../common/channel/DistributionChannel.java | 16 ++---
.../common/channel/MemoryChannel.java | 4 +-
.../channel/bitset/AbstractBitSetChannel.java | 4 +-
.../channel/bitset/AutoAcknowledgeChannel.java | 4 +-
.../common/channel/bitset/BitSetChannel.java | 4 +-
.../channel/bitset/BlockingQueueChannel.java | 4 +-
.../common/channel/bitset/ManualBitSet.java | 2 +-
.../common/constant/ScalingConstant.java | 2 +-
.../common/datasource/DataSourceFactory.java | 2 +-
.../common/datasource/DataSourceManager.java | 2 +-
.../common/datasource/DataSourceWrapper.java | 2 +-
.../{internal => }/common/datasource/JdbcUri.java | 2 +-
.../common/datasource/MetaDataManager.java | 2 +-
.../common/exception/DataCheckFailException.java | 2 +-
.../common/exception/PrepareFailedException.java | 2 +-
.../exception/ScalingJobNotFoundException.java | 2 +-
.../exception/ScalingTaskExecuteException.java | 2 +-
.../UnexpectedDataRecordOrderException.java | 4 +-
.../core/{internal => }/common/record/Column.java | 2 +-
.../{internal => }/common/record/DataRecord.java | 2 +-
.../common/record/FinishedRecord.java | 2 +-
.../common/record/GroupedDataRecord.java | 2 +-
.../common/record/PlaceholderRecord.java | 2 +-
.../core/{internal => }/common/record/Record.java | 2 +-
.../{internal => }/common/record/RecordUtil.java | 2 +-
.../sqlbuilder/AbstractScalingSQLBuilder.java | 6 +-
.../common/sqlbuilder/ScalingSQLBuilder.java | 6 +-
.../sqlbuilder/ScalingSQLBuilderFactory.java | 2 +-
.../scaling/core/config/ScalingContext.java | 14 ++--
.../executor/AbstractScalingExecutor.java | 2 +-
.../{internal => }/executor/ScalingExecutor.java | 2 +-
.../executor/dumper/AbstractJDBCDumper.java | 22 +++---
.../{internal => }/executor/dumper/Dumper.java | 6 +-
.../executor/dumper/DumperFactory.java | 4 +-
.../{internal => }/executor/dumper/JDBCDumper.java | 2 +-
.../{internal => }/executor/dumper/LogDumper.java | 2 +-
.../engine}/ExecuteCallback.java | 2 +-
.../engine/ExecuteEngine.java} | 13 ++--
.../executor/importer/AbstractJDBCImporter.java | 26 +++----
.../executor/importer/DataRecordMerger.java | 14 ++--
.../{internal => }/executor/importer/Importer.java | 6 +-
.../executor/importer/ImporterFactory.java | 4 +-
.../executor/job/FinishedCheckJobExecutor.java | 10 +--
.../executor/job/ScalingJobExecutor.java | 8 +--
.../scaling/core/job/FinishedCheckJob.java | 2 +-
.../scaling/core/job/JobContext.java | 2 +-
.../job/check/AbstractDataConsistencyChecker.java | 8 +--
.../environmental/ScalingEnvironmentalManager.java | 6 +-
.../core/job/position/InventoryPositionGroup.java | 83 ----------------------
.../core/job/preparer/ScalingJobPreparer.java | 4 +-
.../checker/AbstractDataSourceChecker.java | 4 +-
.../preparer/splitter/InventoryTaskSplitter.java | 8 +--
.../job/{position => progress}/JobProgress.java | 7 +-
.../scaling/core/job/{ => progress}/Progress.java | 2 +-
.../scaling/core/job/schedule/JobScheduler.java | 2 +-
.../scaling/core/job/task/ScalingTask.java | 4 +-
.../core/job/task/incremental/IncrementalTask.java | 20 +++---
.../task/incremental/IncrementalTaskProgress.java | 2 +-
.../core/job/task/inventory/InventoryTask.java | 20 +++---
.../job/task/inventory/InventoryTaskProgress.java | 2 +-
.../scaling/core/spi/ScalingEntry.java | 8 +--
.../shardingsphere/scaling/core/util/JDBCUtil.java | 2 +-
.../scaling/core/util/JobConfigurationUtil.java | 2 +-
.../scaling/core/util/ScalingTaskUtil.java | 2 +-
.../common/channel/DistributionChannelTest.java | 10 +--
.../common/channel/MemoryChannelTest.java | 6 +-
.../channel/bitset/AutoAcknowledgeChannelTest.java | 4 +-
.../common/channel/bitset/ManualBitSetTest.java | 2 +-
.../common/datasource/DataSourceFactoryTest.java | 2 +-
.../common/datasource/DataSourceManagerTest.java | 2 +-
.../common/datasource/JdbcUriTest.java | 2 +-
.../common/datasource/MetaDataManagerTest.java | 2 +-
.../common/record/DataRecordTest.java | 2 +-
.../engine/ExecuteEngineTest.java} | 22 +++---
.../importer/AbstractJDBCImporterTest.java | 18 ++---
.../executor/importer/AbstractSqlBuilderTest.java | 10 +--
.../executor/importer/DataRecordMergerTest.java | 12 ++--
.../fixture/FixtureDataConsistencyChecker.java | 2 +-
.../scaling/core/fixture/FixtureH2JDBCDumper.java | 4 +-
.../scaling/core/fixture/FixtureH2LogDumper.java | 4 +-
.../core/fixture/FixtureH2ScalingEntry.java | 8 +--
.../scaling/core/fixture/FixtureNopImporter.java | 6 +-
.../core/fixture/FixtureScalingSQLBuilder.java | 4 +-
.../check/AbstractDataConsistencyCheckerTest.java | 2 +-
.../checker/AbstractDataSourceCheckerTest.java | 4 +-
.../splitter/InventoryTaskSplitterTest.java | 2 +-
.../core/job/task/inventory/InventoryTaskTest.java | 4 +-
.../scaling/mysql/MySQLScalingEntry.java | 8 +--
.../scaling/mysql/component/MySQLBinlogDumper.java | 24 +++----
.../component/MySQLDataConsistencyChecker.java | 4 +-
.../mysql/component/MySQLDataSourceChecker.java | 2 +-
.../scaling/mysql/component/MySQLImporter.java | 6 +-
.../scaling/mysql/component/MySQLJdbcDumper.java | 4 +-
.../mysql/component/MySQLScalingSQLBuilder.java | 8 +--
.../mysql/component/MySQLBinlogDumperTest.java | 14 ++--
.../component/MySQLDataSourceCheckerTest.java | 2 +-
.../scaling/mysql/component/MySQLImporterTest.java | 6 +-
.../mysql/component/MySQLJdbcDumperTest.java | 2 +-
.../component/MySQLScalingSQLBuilderTest.java | 4 +-
.../scaling/postgresql/PostgreSQLScalingEntry.java | 8 +--
.../PostgreSQLDataConsistencyChecker.java | 2 +-
.../component/PostgreSQLDataSourceChecker.java | 4 +-
.../postgresql/component/PostgreSQLImporter.java | 6 +-
.../postgresql/component/PostgreSQLJdbcDumper.java | 4 +-
.../component/PostgreSQLScalingSQLBuilder.java | 10 +--
.../postgresql/component/PostgreSQLWalDumper.java | 10 +--
.../scaling/postgresql/wal/WalEventConverter.java | 16 ++---
.../postgresql/wal/decode/TestDecodingPlugin.java | 4 +-
.../component/PostgreSQLDataSourceCheckerTest.java | 2 +-
.../component/PostgreSQLImporterTest.java | 6 +-
.../component/PostgreSQLJdbcDumperTest.java | 2 +-
.../component/PostgreSQLScalingSQLBuilderTest.java | 4 +-
.../component/PostgreSQLWalDumperTest.java | 4 +-
.../postgresql/wal/WalEventConverterTest.java | 10 +--
.../wal/decode/TestDecodingPluginTest.java | 2 +-
125 files changed, 342 insertions(+), 419 deletions(-)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/channel/AckCallback.java (87%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/channel/Channel.java (90%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/channel/DistributionChannel.java (89%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/channel/MemoryChannel.java (94%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/channel/bitset/AbstractBitSetChannel.java (91%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/channel/bitset/AutoAcknowledgeChannel.java (90%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/channel/bitset/BitSetChannel.java (92%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/channel/bitset/BlockingQueueChannel.java (93%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/channel/bitset/ManualBitSet.java (98%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/constant/ScalingConstant.java (94%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/datasource/DataSourceFactory.java (94%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/datasource/DataSourceManager.java (98%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/datasource/DataSourceWrapper.java (97%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/datasource/JdbcUri.java (97%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/datasource/MetaDataManager.java (96%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/exception/DataCheckFailException.java (93%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/exception/PrepareFailedException.java (94%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/exception/ScalingJobNotFoundException.java (93%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/exception/ScalingTaskExecuteException.java (94%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/exception/UnexpectedDataRecordOrderException.java (87%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/record/Column.java (95%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/record/DataRecord.java (97%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/record/FinishedRecord.java (93%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/record/GroupedDataRecord.java (94%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/record/PlaceholderRecord.java (93%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/record/Record.java (94%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/record/RecordUtil.java (97%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/sqlbuilder/AbstractScalingSQLBuilder.java (96%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/sqlbuilder/ScalingSQLBuilder.java (90%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/sqlbuilder/ScalingSQLBuilderFactory.java (95%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/AbstractScalingExecutor.java (95%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/ScalingExecutor.java (93%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/dumper/AbstractJDBCDumper.java (85%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/dumper/Dumper.java (81%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/dumper/DumperFactory.java (95%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/dumper/JDBCDumper.java (92%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/dumper/LogDumper.java (92%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal/executor
=> executor/engine}/ExecuteCallback.java (94%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal/executor/TaskExecuteEngine.java
=> executor/engine/ExecuteEngine.java} (87%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/importer/AbstractJDBCImporter.java (88%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/importer/DataRecordMerger.java (92%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/importer/Importer.java (81%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/importer/ImporterFactory.java (93%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/job/FinishedCheckJobExecutor.java (84%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/job/ScalingJobExecutor.java (92%)
delete mode 100644
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/position/InventoryPositionGroup.java
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/{position
=> progress}/JobProgress.java (94%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/job/{
=> progress}/Progress.java (93%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/channel/DistributionChannelTest.java (91%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/channel/MemoryChannelTest.java (89%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/channel/bitset/AutoAcknowledgeChannelTest.java (91%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/channel/bitset/ManualBitSetTest.java (97%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/datasource/DataSourceFactoryTest.java (96%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/datasource/DataSourceManagerTest.java (97%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/datasource/JdbcUriTest.java (95%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/datasource/MetaDataManagerTest.java (98%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{internal
=> }/common/record/DataRecordTest.java (97%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{internal/executor/TaskExecuteEngineTest.java
=> executor/engine/ExecuteEngineTest.java} (83%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/importer/AbstractJDBCImporterTest.java (91%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/importer/AbstractSqlBuilderTest.java (89%)
rename
shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{internal
=> }/executor/importer/DataRecordMergerTest.java (96%)
