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