You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by do...@apache.org on 2023/03/15 06:20:33 UTC

[inlong] branch master updated (70744a4c8 -> 9cb8f896c)

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

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


    from 70744a4c8 [INLONG-7611][Dashboard] File source select cluster add limit (#7612)
     add 9cb8f896c [INLONG-7537][Sort] Enable incremental snapshot for MongoDB CDC (#7588)

No new revisions were added by this update.

Summary of changes:
 inlong-sort/sort-connectors/mongodb-cdc/pom.xml    |   6 +
 .../cdc/mongodb}/source/IncrementalSource.java     |  58 +++---
 .../sort/cdc/mongodb/source/MongoDBSource.java     |  94 ++++++++++
 .../cdc/mongodb/source/MongoDBSourceBuilder.java   | 199 +++++++++++++++++++++
 .../reader/IncrementalSourceRecordEmitter.java     |  17 +-
 .../source/reader/MongoDBRecordEmitter.java        | 113 ++++++++++++
 .../sort/cdc/mongodb/table/MongoDBTableSource.java |  90 +++++++---
 .../mongodb/table/MongoDBTableSourceFactory.java   |  19 ++
 licenses/inlong-sort-connectors/LICENSE            |   5 +
 9 files changed, 536 insertions(+), 65 deletions(-)
 copy inlong-sort/sort-connectors/{cdc-base/src/main/java/org/apache/inlong/sort/cdc/base => mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb}/source/IncrementalSource.java (78%)
 create mode 100644 inlong-sort/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/source/MongoDBSource.java
 create mode 100644 inlong-sort/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/source/MongoDBSourceBuilder.java
 copy inlong-sort/sort-connectors/{cdc-base/src/main/java/org/apache/inlong/sort/cdc/base => mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb}/source/reader/IncrementalSourceRecordEmitter.java (91%)
 create mode 100644 inlong-sort/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/source/reader/MongoDBRecordEmitter.java