[shardingsphere] branch master updated (4fba235 -> 36b8ad9)

[me...@apache.org]

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 4fba235  Refactor event for governance and RDL (#9271)
     add 36b8ad9  Optimize scaling package (#9272)

No new revisions were added by this update.

Summary of changes:
 .../scaling/web/HttpServerHandler.java             |  2 +-
 .../scaling/core/api/ScalingAPIFactory.java        |  2 +-
 .../scaling/core/api/ScalingWorker.java            |  4 +--
 .../core/api/impl/RegistryRepositoryAPIImpl.java   |  2 +-
 .../scaling/core/api/impl/ScalingAPIImpl.java      |  4 +--
 .../scaling/core/config/ScalingContext.java        |  2 +-
 .../common}/channel/AckCallback.java               |  4 +--
 .../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 +-
 .../common/datasource}/JdbcUri.java                |  2 +-
 .../common/datasource}/MetaDataManager.java        |  4 +--
 .../common}/exception/DataCheckFailException.java  |  2 +-
 .../common}/exception/PrepareFailedException.java  |  2 +-
 .../exception/ScalingJobNotFoundException.java     |  2 +-
 .../exception/ScalingTaskExecuteException.java     |  2 +-
 .../UnexpectedDataRecordOrderException.java        |  4 +--
 .../common}/record/Column.java                     |  2 +-
 .../common}/record/DataRecord.java                 |  9 +++---
 .../common}/record/FinishedRecord.java             |  2 +-
 .../common}/record/GroupedDataRecord.java          |  2 +-
 .../common}/record/PlaceholderRecord.java          |  2 +-
 .../common}/record/Record.java                     |  4 +--
 .../common}/record/RecordUtil.java                 |  2 +-
 .../sqlbuilder/AbstractScalingSQLBuilder.java      |  6 ++--
 .../common}/sqlbuilder/ScalingSQLBuilder.java      |  6 ++--
 .../sqlbuilder/ScalingSQLBuilderFactory.java       |  2 +-
 .../executor/AbstractScalingExecutor.java          |  2 +-
 .../executor}/ExecuteCallback.java                 |  2 +-
 .../executor/ScalingExecutor.java                  |  2 +-
 .../executor}/TaskExecuteEngine.java               |  3 +-
 .../executor/dumper/AbstractJDBCDumper.java        | 22 ++++++-------
 .../executor/dumper/Dumper.java                    |  6 ++--
 .../executor/dumper/DumperFactory.java             |  4 +--
 .../executor/dumper/JDBCDumper.java                |  2 +-
 .../executor/dumper/LogDumper.java                 |  2 +-
 .../executor/importer/AbstractJDBCImporter.java    | 26 ++++++++--------
 .../executor/importer/DataRecordMerger.java        | 14 ++++-----
 .../executor/importer/Importer.java                |  6 ++--
 .../executor/importer/ImporterFactory.java         |  4 +--
 .../executor/job/FinishedCheckJobExecutor.java     |  6 ++--
 .../executor/job/ScalingJobExecutor.java           | 10 +++---
 .../scaling/core/job/FinishedCheckJob.java         |  2 +-
 .../scaling/core/job/JobContext.java               |  1 -
 .../scaling/core/{schedule => job}/JobStatus.java  |  2 +-
 .../scaling/core/job/ScalingJob.java               |  2 +-
 .../job/check/AbstractDataConsistencyChecker.java  |  8 ++---
 .../environmental/ScalingEnvironmentalManager.java |  6 ++--
 .../scaling/core/job/position/JobProgress.java     |  2 +-
 .../core/job/preparer/ScalingJobPreparer.java      |  6 ++--
 .../checker/AbstractDataSourceChecker.java         |  4 +--
 .../preparer/splitter/InventoryTaskSplitter.java   |  8 ++---
 .../schedule/JobScheduler.java}                    | 36 ++++------------------
 .../{api => job/schedule}/JobSchedulerCenter.java  | 15 ++++-----
 .../scaling/core/job/task/ScalingTask.java         |  2 +-
 .../core/job/task/incremental/IncrementalTask.java | 20 ++++++------
 .../core/job/task/inventory/InventoryTask.java     | 20 ++++++------
 .../scaling/core/spi/ScalingEntry.java             |  8 ++---
 .../shardingsphere/scaling/core/util/JDBCUtil.java |  2 +-
 .../scaling/core/util/JobConfigurationUtil.java    |  2 +-
 .../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 +--
 .../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  |  4 +--
 .../common}/datasource/DataSourceManagerTest.java  |  2 +-
 .../common/datasource}/JdbcUriTest.java            |  2 +-
 .../common/datasource}/MetaDataManagerTest.java    |  2 +-
 .../common}/record/DataRecordTest.java             |  2 +-
 .../executor}/TaskExecuteEngineTest.java           |  3 +-
 .../importer/AbstractJDBCImporterTest.java         | 18 +++++------
 .../executor/importer/AbstractSqlBuilderTest.java  | 10 +++---
 .../executor/importer/DataRecordMergerTest.java    | 12 ++++----
 .../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 +-
 120 files changed, 325 insertions(+), 352 deletions(-)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/channel/AckCallback.java (87%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/channel/Channel.java (90%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/channel/DistributionChannel.java (89%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/channel/MemoryChannel.java (94%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/channel/bitset/AbstractBitSetChannel.java (91%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/channel/bitset/AutoAcknowledgeChannel.java (90%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/channel/bitset/BitSetChannel.java (92%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/channel/bitset/BlockingQueueChannel.java (93%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => 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/{metadata => internal/common/datasource}/JdbcUri.java (97%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{metadata => internal/common/datasource}/MetaDataManager.java (96%)
 mode change 100755 => 100644
 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/{execute/executor => internal/common}/record/Column.java (95%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/record/DataRecord.java (97%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/record/FinishedRecord.java (93%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/record/GroupedDataRecord.java (94%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/record/PlaceholderRecord.java (93%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/record/Record.java (94%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/record/RecordUtil.java (97%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/sqlbuilder/AbstractScalingSQLBuilder.java (96%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/sqlbuilder/ScalingSQLBuilder.java (90%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/sqlbuilder/ScalingSQLBuilderFactory.java (95%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/AbstractScalingExecutor.java (95%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/engine => internal/executor}/ExecuteCallback.java (94%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/ScalingExecutor.java (93%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute/engine => internal/executor}/TaskExecuteEngine.java (97%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/dumper/AbstractJDBCDumper.java (85%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/dumper/Dumper.java (81%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/dumper/DumperFactory.java (95%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/dumper/JDBCDumper.java (92%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/dumper/LogDumper.java (92%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/importer/AbstractJDBCImporter.java (88%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/importer/DataRecordMerger.java (92%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/importer/Importer.java (81%)
 mode change 100755 => 100644
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/importer/ImporterFactory.java (93%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/job/FinishedCheckJobExecutor.java (88%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/job/ScalingJobExecutor.java (90%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{schedule => job}/JobStatus.java (97%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{schedule/ScalingTaskScheduler.java => job/schedule/JobScheduler.java} (78%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/main/java/org/apache/shardingsphere/scaling/core/{api => job/schedule}/JobSchedulerCenter.java (83%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/channel/DistributionChannelTest.java (91%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/channel/MemoryChannelTest.java (89%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/channel/bitset/AutoAcknowledgeChannelTest.java (91%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{execute/executor => 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/{metadata => internal/common/datasource}/JdbcUriTest.java (95%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{metadata => internal/common/datasource}/MetaDataManagerTest.java (98%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{execute/executor => internal/common}/record/DataRecordTest.java (97%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{execute/engine => internal/executor}/TaskExecuteEngineTest.java (95%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/importer/AbstractJDBCImporterTest.java (91%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/importer/AbstractSqlBuilderTest.java (89%)
 rename shardingsphere-scaling/shardingsphere-scaling-core/src/test/java/org/apache/shardingsphere/scaling/core/{execute => internal}/executor/importer/DataRecordMergerTest.java (96%)