This is an automated email from the ASF dual-hosted git repository.

azexin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


    from 50640ab4b7e Adjust checkstyle format (#25331)
     add 26b0b04ed8b Refactor part of pipeline code by pmd results (#25333)

No new revisions were added by this update.

Summary of changes:
 .../cdc/core/importer/SocketSinkImporter.java      | 10 +---
 .../pipeline/cdc/util/ColumnValueConvertUtils.java | 16 ++-----
 .../yaml/YamlPipelineProcessConfiguration.java     | 55 ----------------------
 .../yaml/YamlPipelineReadConfiguration.java        | 23 ---------
 .../yaml/YamlPipelineWriteConfiguration.java       | 21 ---------
 .../AbstractDataConsistencyCalculateAlgorithm.java |  3 +-
 ...RC32MatchDataConsistencyCalculateAlgorithm.java |  3 +-
 ...DataMatchDataConsistencyCalculateAlgorithm.java |  3 +-
 .../core/exception/PipelineInternalException.java  | 14 +++---
 .../data/pipeline/core/execute/ExecuteEngine.java  | 25 +++++-----
 .../memory/MultiplexMemoryPipelineChannel.java     |  2 +-
 .../memory/SimpleMemoryPipelineChannel.java        |  9 ++--
 .../pipeline/core/job/AbstractPipelineJob.java     |  3 +-
 .../StandardPipelineTableMetaDataLoader.java       |  3 +-
 .../metadata/node/PipelineMetaDataNodeWatcher.java | 13 +----
 .../pipeline/mysql/ingest/client/MySQLClient.java  |  7 +--
 .../netty/MySQLBinlogEventPacketDecoder.java       |  3 +-
 .../ingest/client/netty/MySQLNegotiateHandler.java |  3 +-
 .../ingest/wal/decode/MppdbDecodingPlugin.java     |  3 +-
 .../ingest/PostgreSQLPositionInitializer.java      |  3 +-
 .../migration/api/impl/MigrationJobAPI.java        | 12 ++---
 21 files changed, 55 insertions(+), 179 deletions(-)
 copy 
infra/util/src/main/java/org/apache/shardingsphere/infra/util/exception/internal/ShardingSphereInternalException.java
 => 
kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/exception/PipelineInternalException.java
 (66%)

Reply via email to