apache / flink-connector-mongodb
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 49 files with 4,035 lines of code in files.
    • 0 files that are 366+ days old (0 lines of code)
    • 48 files that are 181-365 days old (4,008 lines of code)
    • 1 files that are 91-180 days old (27 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
0% | 99% | <1% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 49 files with 4,035 lines of code in files.
    • 0 files have been last changed 366+ days ago (0 lines of code)
    • 36 files have been last changed 181-365 days ago (3,075 lines of code)
    • 10 files have been last changed 91-180 days ago (513 lines of code)
    • 3 files have been last changed 31-90 days ago (447 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
0% | 76% | 12% | 11% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, xml, md, yml, properties, sql, gitignore, txt, json, editorconfig, yaml
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java0% | 99% | <1% | 0% | 0%
xml0% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java0% | 76% | 12% | 11% | 0%
xml0% | 0% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
flink-connector-mongodb0% | 99% | <1% | 0% | 0%
tools0% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
flink-connector-mongodb0% | 76% | 12% | 11% | 0%
tools0% | 0% | 0% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
BsonToRowDataConverters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter
 364 17 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
RowDataToBsonConverters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter
 273 8 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoWriter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer
 196 8 2023-02-08 2023-06-28 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoDynamicTableSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 167 11 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoScanSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 161 7 2023-02-08 2023-07-12 3 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoDynamicTableFactory.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 160 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoRowDataLookupFunction.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 120 5 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoWriteOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config
 119 16 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoReadOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config
 116 16 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 110 8 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 109 8 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoScanSplitAssigner.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner
 107 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoDynamicTableSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 104 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoConnectorOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 103 1 2023-02-08 2023-02-14 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoKeyExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 101 6 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSampleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 95 5 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoConfiguration.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config
 95 19 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceEnumerator.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 90 8 2023-02-08 2023-07-12 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 88 13 2023-02-08 2023-02-14 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSplitContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 86 12 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoScanSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 81 10 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceEnumStateSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 80 4 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoValidationUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 75 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoShardedSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 72 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceSplitSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 70 5 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoConnectionOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config
 69 12 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitVectorSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 68 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSinkBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 62 9 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSerdeUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 62 5 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader
 61 5 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceReaderContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader
 59 12 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoRowDataSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 56 4 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceEnumState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 48 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 46 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 42 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoRecordEmitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/emitter
 39 5 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
PartitionStrategy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 36 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoConstants.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 32 1 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 31 4 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSingleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 25 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
DefaultMongoSinkContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context
 25 3 2023-02-08 2023-04-03 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoRowDataDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 25 3 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitAssigner.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner
 18 - 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer
 18 1 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer
 17 1 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSinkContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context
 11 - 2023-02-08 2023-04-03 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 8 - 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceSplitState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 8 - 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoScanSourceSplitState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 27 3 2023-02-20 2023-02-20 1 1 jiabao.sun@xtransfer.cn jiabao.sun@xtransfer.cn
suppressions.xml
in tools/maven
 6 -
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
MongoSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 8 - 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer
 17 1 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer
 18 1 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitAssigner.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner
 18 - 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoRowDataDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 25 3 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSingleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 25 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 31 4 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoConstants.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 32 1 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
PartitionStrategy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 36 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 42 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 46 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceEnumState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 48 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoRowDataSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 56 4 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceReaderContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader
 59 12 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSerdeUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 62 5 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSinkBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 62 9 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitVectorSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 68 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoConnectionOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config
 69 12 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoShardedSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 72 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoValidationUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 75 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceEnumStateSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 80 4 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 86 12 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoConfiguration.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config
 95 19 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSampleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 95 5 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoKeyExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 101 6 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoDynamicTableSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 104 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoScanSplitAssigner.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner
 107 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 109 8 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 110 8 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoReadOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config
 116 16 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoWriteOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config
 119 16 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoRowDataLookupFunction.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 120 5 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoDynamicTableFactory.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 160 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoDynamicTableSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 167 11 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
RowDataToBsonConverters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter
 273 8 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
BsonToRowDataConverters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter
 364 17 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 88 13 2023-02-08 2023-02-14 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoConnectorOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 103 1 2023-02-08 2023-02-14 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceSplitState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 8 - 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoScanSourceSplitState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 27 3 2023-02-20 2023-02-20 1 1 jiabao.sun@xtransfer.cn jiabao.sun@xtransfer.cn
MongoRecordEmitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/emitter
 39 5 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader
 61 5 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceSplitSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 70 5 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoScanSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 81 10 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSinkContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context
 11 - 2023-02-08 2023-04-03 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
DefaultMongoSinkContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context
 25 3 2023-02-08 2023-04-03 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoWriter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer
 196 8 2023-02-08 2023-06-28 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceEnumerator.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 90 8 2023-02-08 2023-07-12 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoScanSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 161 7 2023-02-08 2023-07-12 3 2 328226527@qq.com jiabao.sun@xtransfer.cn
suppressions.xml
in tools/maven
 6 -
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
suppressions.xml
in tools/maven
 6 -
MongoScanSourceSplitState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 27 3 2023-02-20 2023-02-20 1 1 jiabao.sun@xtransfer.cn jiabao.sun@xtransfer.cn
BsonToRowDataConverters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter
 364 17 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
RowDataToBsonConverters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter
 273 8 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoWriter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer
 196 8 2023-02-08 2023-06-28 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoDynamicTableSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 167 11 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoScanSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 161 7 2023-02-08 2023-07-12 3 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoDynamicTableFactory.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 160 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoRowDataLookupFunction.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 120 5 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoWriteOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config
 119 16 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoReadOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config
 116 16 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 110 8 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 109 8 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoScanSplitAssigner.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner
 107 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoDynamicTableSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 104 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoConnectorOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 103 1 2023-02-08 2023-02-14 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoKeyExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 101 6 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSampleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 95 5 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoConfiguration.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config
 95 19 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceEnumerator.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 90 8 2023-02-08 2023-07-12 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 88 13 2023-02-08 2023-02-14 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSplitContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 86 12 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoScanSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 81 10 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceEnumStateSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 80 4 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoValidationUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 75 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoShardedSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 72 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceSplitSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 70 5 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoConnectionOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config
 69 12 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitVectorSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 68 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSinkBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 62 9 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSerdeUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 62 5 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader
 61 5 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceReaderContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader
 59 12 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoRowDataSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 56 4 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceEnumState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 48 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 46 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 42 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoRecordEmitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/emitter
 39 5 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
PartitionStrategy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 36 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoConstants.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 32 1 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 31 4 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSingleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 25 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
DefaultMongoSinkContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context
 25 3 2023-02-08 2023-04-03 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoRowDataDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 25 3 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitAssigner.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner
 18 - 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer
 18 1 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer
 17 1 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSinkContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context
 11 - 2023-02-08 2023-04-03 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 8 - 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceSplitState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 8 - 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
suppressions.xml
in tools/maven
 6 -
MongoScanSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 161 7 2023-02-08 2023-07-12 3 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceEnumerator.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 90 8 2023-02-08 2023-07-12 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoWriter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer
 196 8 2023-02-08 2023-06-28 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
DefaultMongoSinkContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context
 25 3 2023-02-08 2023-04-03 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSinkContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context
 11 - 2023-02-08 2023-04-03 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoScanSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 81 10 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceSplitSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 70 5 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader
 61 5 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoRecordEmitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/emitter
 39 5 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoScanSourceSplitState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 27 3 2023-02-20 2023-02-20 1 1 jiabao.sun@xtransfer.cn jiabao.sun@xtransfer.cn
MongoSourceSplitState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 8 - 2023-02-08 2023-02-20 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoConnectorOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 103 1 2023-02-08 2023-02-14 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 88 13 2023-02-08 2023-02-14 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
BsonToRowDataConverters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter
 364 17 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
RowDataToBsonConverters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter
 273 8 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoDynamicTableSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 167 11 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoDynamicTableFactory.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 160 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoRowDataLookupFunction.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 120 5 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoWriteOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config
 119 16 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoReadOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config
 116 16 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 110 8 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 109 8 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoScanSplitAssigner.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner
 107 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoDynamicTableSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 104 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoKeyExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 101 6 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSampleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 95 5 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoConfiguration.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config
 95 19 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 86 12 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceEnumStateSerializer.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 80 4 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoValidationUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 75 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoShardedSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 72 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoConnectionOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config
 69 12 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitVectorSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 68 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSinkBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 62 9 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSerdeUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 62 5 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceReaderContext.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader
 59 12 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoRowDataSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 56 4 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceEnumState.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator
 48 7 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 46 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink
 42 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
PartitionStrategy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 36 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoConstants.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 32 1 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 31 4 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSingleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 25 2 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoRowDataDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 25 3 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSplitAssigner.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner
 18 - 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer
 18 1 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoDeserializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer
 17 1 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com
MongoSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 8 - 2023-02-08 2023-02-08 1 1 328226527@qq.com 328226527@qq.com