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
