This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git.
from 00d60fb Add 'connector/rocketmq-connect-kafka/' from commit
'59ac9fd7b7fd11ad7943b5ef30a3f95b20acadd7'
new f629088 add junit test and modify some code
new 6ca400a add junit test and modify some code
new e84812e 修改stop
new 32d3165 fix some bug
new 70caed3 fix some bug
new 6777f23 fix bug
new f95bf22 support multiple mongo replicaset
new 98da0fb fix test verifyConfig
new f193fcd reformat code and add more test case
new 2cdb27a fix some bug and add readme
new db51f7f clean code
new b307466 bump up the connect version to 0.1.1
new 232c585 Add 'connector/rocketmq-connect-mongo/' from commit
'b307466f3fc4fa25ba21de87c568a4095cf18f4f'
The 13 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
connector/rocketmq-connect-mongo/README.md | 43 ++++
.../rocketmq-connect-mongo}/pom.xml | 102 ++++----
.../org/apache/connect/mongo/SourceTaskConfig.java | 266 +++++++++++++++++++++
.../mongo/connector/MongoSourceConnector.java} | 28 ++-
.../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 +++++++++++++
.../connect/mongo/replicator/Constants.java} | 27 +--
.../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} | 28 +--
.../apache/connect/mongo/ReplicaContextTest.java | 33 +++
.../connect/mongo/ReplicaSetManagerTest.java | 58 +++++
.../org/apache/connect/mongo/ReplicaSetTest.java | 59 +++++
29 files changed, 2728 insertions(+), 97 deletions(-)
create mode 100644 connector/rocketmq-connect-mongo/README.md
copy {rocketmq-connect-cli => connector/rocketmq-connect-mongo}/pom.xml (72%)
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/SourceTaskConfig.java
copy
connector/{rocketmq-connect-activemq/src/main/java/org/apache/rocketmq/connect/activemq/connector/ActivemqSourceConnector.java
=>
rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceConnector.java}
(70%)
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/MongoSourceTask.java
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/connector/builder/MongoDataEntry.java
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/CollectionMeta.java
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/initsync/InitSync.java
copy
connector/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/DefaultColumnParser.java
=>
rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Constants.java}
(56%)
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/MongoClientFactory.java
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/OperationFilter.java
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/Position.java
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSet.java
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetConfig.java
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetManager.java
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicaSetsContext.java
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/ReplicatorTask.java
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/Document2EventConverter.java
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/OperationType.java
create mode 100644
connector/rocketmq-connect-mongo/src/main/java/org/apache/connect/mongo/replicator/event/ReplicationEvent.java
create mode 100644
connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/FilterTest.java
create mode 100644
connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoFactoryTest.java
create mode 100644
connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceConnectorTest.java
create mode 100644
connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoSourceTaskTest.java
create mode 100644
connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/MongoTest.java
copy
connector/{rocketmq-connect-kafka/src/test/java/org/apache/rocketmq/connect/kafka/connector/KafkaSourceTaskTest.java
=>
rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/OperationTypeTest.java}
(52%)
create mode 100644
connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaContextTest.java
create mode 100644
connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetManagerTest.java
create mode 100644
connector/rocketmq-connect-mongo/src/test/java/org/apache/connect/mongo/ReplicaSetTest.java
