You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by zh...@apache.org on 2022/12/12 11:39:43 UTC
[shardingsphere] branch master updated (c1845a7d1f8 -> a6d910d24b3)

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

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


    from c1845a7d1f8 Rename ClassPointcuts (#22818)
     add a6d910d24b3 Add partial implementation of CDC subscription FULL mode (#22779)

No new revisions were added by this update.

Summary of changes:
 .../pipeline/api/datanode/JobDataNodeEntry.java    |  21 ++++
 .../pipeline/api/datanode/JobDataNodeLine.java     |  14 +++
 ...rdingSpherePipelineDataSourceConfiguration.java |  12 +++
 .../cdc/client/handler/LoginRequestHandler.java    |   2 +-
 .../data/pipeline/cdc/api/CDCJobAPI.java           |  15 ++-
 .../data/pipeline/cdc/api/impl/CDCJobAPIImpl.java  | 114 ++++++++++++++++----
 .../cdc/config/job/CDCJobConfiguration.java        |  13 ++-
 .../cdc/config/task/CDCTaskConfiguration.java}     |  13 +--
 .../pipeline/cdc/context/CDCProcessContext.java}   |  16 +--
 .../cdc/context/job/CDCJobItemContext.java}        |  86 ++++++---------
 .../data/pipeline/cdc/core/job/CDCJob.java         |  33 +++++-
 .../CDCJobConfigurationChangedProcessor.java       |   9 +-
 .../pipeline/cdc/core/prepare/CDCJobPreparer.java  |  71 +++++++++++++
 .../cdc/yaml/job/YamlCDCJobConfiguration.java      |   9 +-
 .../yaml/job/YamlCDCJobConfigurationSwapper.java   |  20 +++-
 ...ngsphere.data.pipeline.core.api.PipelineJobAPI} |   0
 .../job/YamlCDCJobConfigurationSwapperTest.java    |  45 ++++++++
 .../core/util/JobDataNodeLineConvertUtil.java      |  68 ++++++++++++
 .../core/util/JobDataNodeLineConvertUtilTest.java  |  66 ++++++++++++
 .../handler/cdc/fixture/FixtureCDCJobAPI.java      | 116 ++++++++++++++++++++-
 .../pipeline/api/datanode/JobDataNodeLineTest.java |  12 +++
 21 files changed, 641 insertions(+), 114 deletions(-)
 copy kernel/data-pipeline/{scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/config/MigrationTaskConfiguration.java => cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/config/task/CDCTaskConfiguration.java} (75%)
 copy kernel/data-pipeline/{scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/context/MigrationProcessContext.java => cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/context/CDCProcessContext.java} (68%)
 copy kernel/data-pipeline/{scenario/migration/src/main/java/org/apache/shardingsphere/data/pipeline/scenario/migration/context/MigrationJobItemContext.java => cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/context/job/CDCJobItemContext.java} (61%)
 create mode 100644 kernel/data-pipeline/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/prepare/CDCJobPreparer.java
 copy kernel/data-pipeline/cdc/core/src/main/resources/META-INF/services/{org.apache.shardingsphere.data.pipeline.cdc.api.CDCJobAPI => org.apache.shardingsphere.data.pipeline.core.api.PipelineJobAPI} (100%)
 create mode 100644 kernel/data-pipeline/cdc/core/src/test/java/org/apache/shardingsphere/data/pipeline/cdc/yaml/job/YamlCDCJobConfigurationSwapperTest.java
 create mode 100644 kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/util/JobDataNodeLineConvertUtil.java
 create mode 100644 kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/util/JobDataNodeLineConvertUtilTest.java