path # lines of code # active days days since first update days since last update # commits # contributors first updated last updated first contributor last contributor flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoSourceSplitReader.java 8 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java 161 3 185 31 3 2 2023-02-08 2023-07-12 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer/MongoDeserializationSchema.java 17 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/emitter/MongoRecordEmitter.java 39 2 185 173 2 2 2023-02-08 2023-02-20 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReaderContext.java 59 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReader.java 61 2 185 173 2 2 2023-02-08 2023-02-20 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitSerializer.java 70 2 185 173 2 2 2023-02-08 2023-02-20 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoScanSourceSplitState.java 27 1 173 173 1 1 2023-02-20 2023-02-20 jiabao.sun@xtransfer.cn jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoScanSourceSplit.java 81 2 185 173 2 2 2023-02-08 2023-02-20 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitState.java 8 2 185 173 2 2 2023-02-08 2023-02-20 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplit.java 31 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSource.java 110 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config/MongoReadOptions.java 116 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSourceBuilder.java 88 2 185 179 2 2 2023-02-08 2023-02-14 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumState.java 48 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSingleSplitter.java 25 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/PartitionStrategy.java 36 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitContext.java 86 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitVectorSplitter.java 68 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoShardedSplitter.java 72 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitters.java 46 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSampleSplitter.java 95 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumStateSerializer.java 80 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumerator.java 90 2 185 31 2 2 2023-02-08 2023-07-12 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner/MongoScanSplitAssigner.java 107 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner/MongoSplitAssigner.java 18 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config/MongoWriteOptions.java 119 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer/MongoSerializationSchema.java 18 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context/DefaultMongoSinkContext.java 25 2 185 131 2 2 2023-02-08 2023-04-03 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context/MongoSinkContext.java 11 2 185 131 2 2 2023-02-08 2023-04-03 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriter.java 196 2 185 45 2 2 2023-02-08 2023-06-28 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/MongoSink.java 42 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/MongoSinkBuilder.java 62 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config/MongoConnectionOptions.java 69 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoSerdeUtils.java 62 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoUtils.java 109 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoConstants.java 32 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoValidationUtils.java 75 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/RowDataToBsonConverters.java 273 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/BsonToRowDataConverters.java 364 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config/MongoConfiguration.java 95 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java 160 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization/MongoRowDataDeserializationSchema.java 25 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization/MongoRowDataSerializationSchema.java 56 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSink.java 104 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoConnectorOptions.java 103 2 185 179 2 2 2023-02-08 2023-02-14 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSource.java 167 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoKeyExtractor.java 101 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoRowDataLookupFunction.java 120 1 185 185 1 1 2023-02-08 2023-02-08 328226527@qq.com 328226527@qq.com