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 <[email protected]> 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
