You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 03:22:36 UTC
[rocketmq-connect] 13/13: Add 'connector/rocketmq-connect-mongo/' from commit 'b307466f3fc4fa25ba21de87c568a4095cf18f4f'
This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit 232c585fdee7e6a0ab6d7aef04140019bc9a3be7
Merge: 00d60fb b307466
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 11:21:49 2022 +0800
Add 'connector/rocketmq-connect-mongo/' from commit 'b307466f3fc4fa25ba21de87c568a4095cf18f4f'
git-subtree-dir: connector/rocketmq-connect-mongo
git-subtree-mainline: 00d60fb18f82dd396d1ebc0423cde95f32f8fa9e
git-subtree-split: b307466f3fc4fa25ba21de87c568a4095cf18f4f
connector/rocketmq-connect-mongo/README.md | 43 ++++
connector/rocketmq-connect-mongo/pom.xml | 180 ++++++++++++++
.../org/apache/connect/mongo/SourceTaskConfig.java | 266 +++++++++++++++++++++
.../mongo/connector/MongoSourceConnector.java | 76 ++++++
.../connect/mongo/connector/MongoSourceTask.java | 105 ++++++++
.../mongo/connector/builder/MongoDataEntry.java | 134 +++++++++++
.../connect/mongo/initsync/CollectionMeta.java | 58 +++++
.../apache/connect/mongo/initsync/InitSync.java | 163 +++++++++++++
.../apache/connect/mongo/replicator/Constants.java | 36 +++
.../mongo/replicator/MongoClientFactory.java | 129 ++++++++++
.../connect/mongo/replicator/OperationFilter.java | 80 +++++++
.../apache/connect/mongo/replicator/Position.java | 85 +++++++
.../connect/mongo/replicator/ReplicaSet.java | 112 +++++++++
.../connect/mongo/replicator/ReplicaSetConfig.java | 75 ++++++
.../mongo/replicator/ReplicaSetManager.java | 85 +++++++
.../mongo/replicator/ReplicaSetsContext.java | 121 ++++++++++
.../connect/mongo/replicator/ReplicatorTask.java | 128 ++++++++++
.../replicator/event/Document2EventConverter.java | 49 ++++
.../mongo/replicator/event/OperationType.java | 62 +++++
.../mongo/replicator/event/ReplicationEvent.java | 176 ++++++++++++++
.../java/org/apache/connect/mongo/FilterTest.java | 67 ++++++
.../org/apache/connect/mongo/MongoFactoryTest.java | 177 ++++++++++++++
.../connect/mongo/MongoSourceConnectorTest.java | 95 ++++++++
.../apache/connect/mongo/MongoSourceTaskTest.java | 142 +++++++++++
.../java/org/apache/connect/mongo/MongoTest.java | 138 +++++++++++
.../apache/connect/mongo/OperationTypeTest.java | 37 +++
.../apache/connect/mongo/ReplicaContextTest.java | 33 +++
.../connect/mongo/ReplicaSetManagerTest.java | 58 +++++
.../org/apache/connect/mongo/ReplicaSetTest.java | 59 +++++
29 files changed, 2969 insertions(+)
diff --cc connector/rocketmq-connect-mongo/README.md
index 0000000,bec30a3..bec30a3
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/README.md
+++ b/connector/rocketmq-connect-mongo/README.md
diff --cc connector/rocketmq-connect-mongo/pom.xml
index 0000000,5c412bf..5c412bf
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/pom.xml
+++ b/connector/rocketmq-connect-mongo/pom.xml
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java
index 0000000,d184b5c..d184b5c
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceConnector.java
index 0000000,5be2e0d..5be2e0d
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceConnector.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceConnector.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java
index 0000000,49bcf49..49bcf49
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/builder/MongoDataEntry.java
index 0000000,1d6dfe5..1d6dfe5
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/builder/MongoDataEntry.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/builder/MongoDataEntry.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/CollectionMeta.java
index 0000000,4af5060..4af5060
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/CollectionMeta.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/CollectionMeta.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/InitSync.java
index 0000000,a51b727..a51b727
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/InitSync.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/InitSync.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Constants.java
index 0000000,7ba1ac4..7ba1ac4
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Constants.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Constants.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/MongoClientFactory.java
index 0000000,11bca8f..11bca8f
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/MongoClientFactory.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/MongoClientFactory.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/OperationFilter.java
index 0000000,a173f6c..a173f6c
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/OperationFilter.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/OperationFilter.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java
index 0000000,29fd856..29fd856
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSet.java
index 0000000,8393316..8393316
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSet.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSet.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetConfig.java
index 0000000,ced90b8..ced90b8
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetConfig.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetConfig.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetManager.java
index 0000000,88097d8..88097d8
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetManager.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetManager.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetsContext.java
index 0000000,8dd85d7..8dd85d7
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetsContext.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetsContext.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicatorTask.java
index 0000000,cd78f24..cd78f24
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicatorTask.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicatorTask.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/Document2EventConverter.java
index 0000000,99ab707..99ab707
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/Document2EventConverter.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/Document2EventConverter.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/OperationType.java
index 0000000,b418666..b418666
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/OperationType.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/OperationType.java
diff --cc connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java
index 0000000,7adca71..7adca71
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java
+++ b/connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java
diff --cc connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/FilterTest.java
index 0000000,d5deefd..d5deefd
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/FilterTest.java
+++ b/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/FilterTest.java
diff --cc connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoFactoryTest.java
index 0000000,e47d2c4..e47d2c4
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoFactoryTest.java
+++ b/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoFactoryTest.java
diff --cc connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceConnectorTest.java
index 0000000,cc02fbc..cc02fbc
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceConnectorTest.java
+++ b/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceConnectorTest.java
diff --cc connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceTaskTest.java
index 0000000,4983a66..4983a66
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceTaskTest.java
+++ b/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceTaskTest.java
diff --cc connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoTest.java
index 0000000,3d900fa..3d900fa
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoTest.java
+++ b/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoTest.java
diff --cc connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/OperationTypeTest.java
index 0000000,d8c5a9b..d8c5a9b
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/OperationTypeTest.java
+++ b/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/OperationTypeTest.java
diff --cc connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaContextTest.java
index 0000000,16cb959..16cb959
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaContextTest.java
+++ b/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaContextTest.java
diff --cc connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetManagerTest.java
index 0000000,1d3b743..1d3b743
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetManagerTest.java
+++ b/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetManagerTest.java
diff --cc connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetTest.java
index 0000000,07eefae..07eefae
mode 000000,100644..100644
--- a/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetTest.java
+++ b/connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetTest.java