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/common/utils/MongoConstants.java 34 2 820 157 2 2 2023-02-08 2024-12-02 328226527@qq.com 34335406+yuxiqian@users.noreply.github.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoUtils.java 109 1 820 820 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 820 820 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 2 820 296 2 2 2023-02-08 2024-07-16 328226527@qq.com jiabaosun@apache.org flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config/MongoConnectionOptions.java 69 1 820 820 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 132 3 820 106 3 2 2023-02-08 2025-01-22 328226527@qq.com jiabaosun@apache.org flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java 157 5 820 92 5 3 2023-02-08 2025-02-05 328226527@qq.com 34335406+yuxiqian@users.noreply.github.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSource.java 229 3 820 275 3 3 2023-02-08 2024-08-06 328226527@qq.com jiabaosun@apache.org flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config/MongoConfiguration.java 104 3 820 157 3 3 2023-02-08 2024-12-02 328226527@qq.com 34335406+yuxiqian@users.noreply.github.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/FilterHandlingPolicy.java 24 2 275 69 2 2 2024-08-06 2025-02-28 jiabaosun@apache.org lixiangwd@gmail.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoPrimaryKeyExtractor.java 101 1 296 296 1 1 2024-07-16 2024-07-16 jiabaosun@apache.org jiabaosun@apache.org flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization/MongoRowDataDeserializationSchema.java 25 1 820 820 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 63 2 820 296 2 2 2023-02-08 2024-07-16 328226527@qq.com jiabaosun@apache.org flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoShardKeysExtractor.java 75 1 296 296 1 1 2024-07-16 2024-07-16 jiabaosun@apache.org jiabaosun@apache.org flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/RowDataToBsonConverters.java 273 1 820 820 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 820 820 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/MongoFilterPushDownVisitor.java 204 1 469 469 1 1 2024-01-25 2024-01-25 jiabao.sun@xtransfer.cn jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoRowDataLookupFunction.java 120 1 820 820 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 117 4 820 157 4 4 2023-02-08 2024-12-02 328226527@qq.com 34335406+yuxiqian@users.noreply.github.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config/MongoWriteOptions.java 119 1 820 820 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/MongoSink.java 42 1 820 820 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 820 820 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/MongoSinkContext.java 11 2 820 766 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/DefaultMongoSinkContext.java 25 2 820 766 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 820 680 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/MongoSinkBuilder.java 62 1 820 820 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 115 2 820 469 2 2 2023-02-08 2024-01-25 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config/MongoReadOptions.java 139 3 820 92 3 2 2023-02-08 2025-02-05 328226527@qq.com 34335406+yuxiqian@users.noreply.github.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSourceBuilder.java 96 3 820 469 3 2 2023-02-08 2024-01-25 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner/MongoSplitAssigner.java 18 1 820 820 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/MongoScanSplitAssigner.java 107 1 820 820 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 820 820 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 820 820 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 40 2 820 157 2 2 2023-02-08 2024-12-02 328226527@qq.com 34335406+yuxiqian@users.noreply.github.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSingleSplitter.java 23 2 820 157 2 2 2023-02-08 2024-12-02 328226527@qq.com 34335406+yuxiqian@users.noreply.github.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoPaginationSplitter.java 85 1 157 157 1 1 2024-12-02 2024-12-02 34335406+yuxiqian@users.noreply.github.com 34335406+yuxiqian@users.noreply.github.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSampleSplitter.java 95 2 820 157 2 2 2023-02-08 2024-12-02 328226527@qq.com 34335406+yuxiqian@users.noreply.github.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitVectorSplitter.java 68 2 820 157 2 2 2023-02-08 2024-12-02 328226527@qq.com 34335406+yuxiqian@users.noreply.github.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitters.java 48 2 820 157 2 2 2023-02-08 2024-12-02 328226527@qq.com 34335406+yuxiqian@users.noreply.github.com flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoShardedSplitter.java 72 1 820 820 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 820 666 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/MongoSourceEnumState.java 48 1 820 820 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/split/MongoSourceSplitState.java 8 2 820 808 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 820 820 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/split/MongoScanSourceSplit.java 100 3 820 576 3 2 2023-02-08 2023-10-10 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitSerializer.java 70 2 820 808 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 808 808 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/reader/MongoSourceReaderContext.java 59 1 820 820 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/deserializer/MongoDeserializationSchema.java 17 1 820 820 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 820 808 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/split/MongoScanSourceSplitReader.java 165 5 820 469 5 2 2023-02-08 2024-01-25 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoSourceSplitReader.java 8 2 820 576 2 2 2023-02-08 2023-10-10 328226527@qq.com jiabao.sun@xtransfer.cn flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReader.java 61 2 820 808 2 2 2023-02-08 2023-02-20 328226527@qq.com jiabao.sun@xtransfer.cn