apache / flink-connector-mongodb
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 53 files with 4,605 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 0 files changed 6-20 times (0 lines of code)
    • 53 files changed 1-5 times (4,605 lines of code)
0% | 0% | 0% | 0% | 100%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 53 files with 4,605 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 0 files changed by 6-10 contributors (0 lines of code)
    • 28 files changed by 2-5 contributors (2,332 lines of code)
    • 25 files changed by 1 contributor (2,273 lines of code)
0% | 0% | 0% | 50% | 49%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, xml, md, yaml, properties, sql, gitignore, txt, editorconfig, gitmodules
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 0%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
flink-connector-mongodb0% | 0% | 0% | 0% | 100%
tools0% | 0% | 0% | 0% | 0%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
MongoDynamicTableFactory.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 157 7 2023-02-08 2025-02-05 5 3 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoScanSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 165 7 2023-02-08 2024-01-25 5 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoConnectorOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 117 1 2023-02-08 2024-12-02 4 4 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoSourceBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 96 14 2023-02-08 2024-01-25 3 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoScanSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 100 11 2023-02-08 2023-10-10 3 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoConfiguration.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config
 104 21 2023-02-08 2024-12-02 3 3 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoDynamicTableSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 132 9 2023-02-08 2025-01-22 3 2 328226527@qq.com jiabaosun@apache.org
MongoReadOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config
 139 17 2023-02-08 2025-02-05 3 2 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoDynamicTableSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 229 13 2023-02-08 2024-08-06 3 3 328226527@qq.com jiabaosun@apache.org
MongoSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 8 - 2023-02-08 2023-10-10 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
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
MongoSingleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 23 2 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
FilterHandlingPolicy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 24 2 2024-08-06 2025-02-28 2 2 jiabaosun@apache.org lixiangwd@gmail.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
MongoConstants.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 34 1 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
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
 40 2 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoSplitters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 48 2 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
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
MongoRowDataSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 63 4 2023-02-08 2024-07-16 2 2 328226527@qq.com jiabaosun@apache.org
MongoSplitVectorSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 68 2 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
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
MongoValidationUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 75 2 2023-02-08 2024-07-16 2 2 328226527@qq.com jiabaosun@apache.org
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
MongoSampleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 95 5 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 115 8 2023-02-08 2024-01-25 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
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
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
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
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
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
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
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
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
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
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
MongoShardKeysExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 75 4 2024-07-16 2024-07-16 1 1 jiabaosun@apache.org jiabaosun@apache.org
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
MongoPaginationSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 85 1 2024-12-02 2024-12-02 1 1 34335406+yuxiqian@users.nor... 34335406+yuxiqian@users.nor...
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
MongoPrimaryKeyExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 101 6 2024-07-16 2024-07-16 1 1 jiabaosun@apache.org jiabaosun@apache.org
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
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
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
MongoConnectorOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 117 1 2023-02-08 2024-12-02 4 4 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoDynamicTableFactory.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 157 7 2023-02-08 2025-02-05 5 3 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoDynamicTableSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 229 13 2023-02-08 2024-08-06 3 3 328226527@qq.com jiabaosun@apache.org
MongoConfiguration.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config
 104 21 2023-02-08 2024-12-02 3 3 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoScanSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 165 7 2023-02-08 2024-01-25 5 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoDynamicTableSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 132 9 2023-02-08 2025-01-22 3 2 328226527@qq.com jiabaosun@apache.org
MongoReadOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config
 139 17 2023-02-08 2025-02-05 3 2 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoSourceBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 96 14 2023-02-08 2024-01-25 3 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoScanSourceSplit.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split
 100 11 2023-02-08 2023-10-10 3 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoConstants.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 34 1 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoValidationUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 75 2 2023-02-08 2024-07-16 2 2 328226527@qq.com jiabaosun@apache.org
FilterHandlingPolicy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 24 2 2024-08-06 2025-02-28 2 2 jiabaosun@apache.org lixiangwd@gmail.com
MongoRowDataSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 63 4 2023-02-08 2024-07-16 2 2 328226527@qq.com jiabaosun@apache.org
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
MongoSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 115 8 2023-02-08 2024-01-25 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
 40 2 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoSingleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 23 2 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoSampleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 95 5 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoSplitVectorSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 68 2 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoSplitters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 48 2 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
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
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
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
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
MongoSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 8 - 2023-02-08 2023-10-10 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
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
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
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
MongoPrimaryKeyExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 101 6 2024-07-16 2024-07-16 1 1 jiabaosun@apache.org jiabaosun@apache.org
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
MongoShardKeysExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 75 4 2024-07-16 2024-07-16 1 1 jiabaosun@apache.org jiabaosun@apache.org
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
MongoFilterPushDownVisitor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 204 9 2024-01-25 2024-01-25 1 1 jiabao.sun@xtransfer.cn jiabao.sun@xtransfer.cn
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
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
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
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
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
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
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
MongoPaginationSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 85 1 2024-12-02 2024-12-02 1 1 34335406+yuxiqian@users.nor... 34335406+yuxiqian@users.nor...
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
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
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
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
suppressions.xml
in tools/maven
 6 -
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
MongoFilterPushDownVisitor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 204 9 2024-01-25 2024-01-25 1 1 jiabao.sun@xtransfer.cn jiabao.sun@xtransfer.cn
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
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
MongoPrimaryKeyExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 101 6 2024-07-16 2024-07-16 1 1 jiabaosun@apache.org jiabaosun@apache.org
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
MongoPaginationSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 85 1 2024-12-02 2024-12-02 1 1 34335406+yuxiqian@users.nor... 34335406+yuxiqian@users.nor...
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
MongoShardKeysExtractor.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 75 4 2024-07-16 2024-07-16 1 1 jiabaosun@apache.org jiabaosun@apache.org
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
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
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
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
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
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
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
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
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
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
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
MongoScanSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 165 7 2023-02-08 2024-01-25 5 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoReadOptions.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config
 139 17 2023-02-08 2025-02-05 3 2 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoDynamicTableSink.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 132 9 2023-02-08 2025-01-22 3 2 328226527@qq.com jiabaosun@apache.org
MongoSource.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 115 8 2023-02-08 2024-01-25 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
 100 11 2023-02-08 2023-10-10 3 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSourceBuilder.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source
 96 14 2023-02-08 2024-01-25 3 2 328226527@qq.com jiabao.sun@xtransfer.cn
MongoSampleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 95 5 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
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
MongoValidationUtils.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 75 2 2023-02-08 2024-07-16 2 2 328226527@qq.com jiabaosun@apache.org
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
MongoSplitVectorSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 68 2 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
MongoRowDataSerializationSchema.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization
 63 4 2023-02-08 2024-07-16 2 2 328226527@qq.com jiabaosun@apache.org
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
MongoSplitters.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 48 2 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
PartitionStrategy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 40 2 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
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
MongoConstants.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils
 34 1 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
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
FilterHandlingPolicy.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table
 24 2 2024-08-06 2025-02-28 2 2 jiabaosun@apache.org lixiangwd@gmail.com
MongoSingleSplitter.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter
 23 2 2023-02-08 2024-12-02 2 2 328226527@qq.com 34335406+yuxiqian@users.nor...
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
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
MongoSourceSplitReader.java
in flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split
 8 - 2023-02-08 2023-10-10 2 2 328226527@qq.com jiabao.sun@xtransfer.cn
Correlations

File Size vs. Number of Changes: 53 points

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/FilterHandlingPolicy.java x: 24 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config/MongoReadOptions.java x: 139 lines of code y: 3 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java x: 157 lines of code y: 5 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSink.java x: 132 lines of code y: 3 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoConstants.java x: 34 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoPaginationSplitter.java x: 85 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSampleSplitter.java x: 95 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSingleSplitter.java x: 23 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitVectorSplitter.java x: 68 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitters.java x: 48 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/PartitionStrategy.java x: 40 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoConnectorOptions.java x: 117 lines of code y: 4 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config/MongoConfiguration.java x: 104 lines of code y: 3 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSource.java x: 229 lines of code y: 3 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoValidationUtils.java x: 75 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoPrimaryKeyExtractor.java x: 101 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoShardKeysExtractor.java x: 75 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization/MongoRowDataSerializationSchema.java x: 63 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSource.java x: 115 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSourceBuilder.java x: 96 lines of code y: 3 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java x: 165 lines of code y: 5 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoFilterPushDownVisitor.java x: 204 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoSourceSplitReader.java x: 8 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoScanSourceSplit.java x: 100 lines of code y: 3 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumerator.java x: 90 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriter.java x: 196 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context/DefaultMongoSinkContext.java x: 25 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context/MongoSinkContext.java x: 11 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReader.java x: 61 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/emitter/MongoRecordEmitter.java x: 39 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoScanSourceSplitState.java x: 27 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitSerializer.java x: 70 lines of code y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config/MongoConnectionOptions.java x: 69 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoSerdeUtils.java x: 62 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoUtils.java x: 109 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/MongoSink.java x: 42 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config/MongoWriteOptions.java x: 119 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer/MongoSerializationSchema.java x: 18 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumState.java x: 48 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumStateSerializer.java x: 80 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner/MongoScanSplitAssigner.java x: 107 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoShardedSplitter.java x: 72 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitContext.java x: 86 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReaderContext.java x: 59 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer/MongoDeserializationSchema.java x: 17 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplit.java x: 31 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoRowDataLookupFunction.java x: 120 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/BsonToRowDataConverters.java x: 364 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/RowDataToBsonConverters.java x: 273 lines of code y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization/MongoRowDataDeserializationSchema.java x: 25 lines of code y: 1 # changes
5.0
# changes
  min: 1.0
  average: 1.79
  25th percentile: 1.0
  median: 2.0
  75th percentile: 2.0
  max: 5.0
0 364.0
lines of code
min: 8.0 | average: 86.89 | 25th percentile: 36.5 | median: 72.0 | 75th percentile: 112.0 | max: 364.0

Number of Contributors vs. Number of Changes: 53 points

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/FilterHandlingPolicy.java x: 2 # contributors y: 2 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config/MongoReadOptions.java x: 2 # contributors y: 3 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java x: 3 # contributors y: 5 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoPaginationSplitter.java x: 1 # contributors y: 1 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoConnectorOptions.java x: 4 # contributors y: 4 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config/MongoConfiguration.java x: 3 # contributors y: 3 # changes flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java x: 2 # contributors y: 5 # changes
5.0
# changes
  min: 1.0
  average: 1.79
  25th percentile: 1.0
  median: 2.0
  75th percentile: 2.0
  max: 5.0
0 4.0
# contributors
min: 1.0 | average: 1.62 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 4.0

Number of Contributors vs. File Size: 53 points

flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/FilterHandlingPolicy.java x: 2 # contributors y: 24 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/config/MongoReadOptions.java x: 2 # contributors y: 139 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableFactory.java x: 3 # contributors y: 157 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSink.java x: 2 # contributors y: 132 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoConstants.java x: 2 # contributors y: 34 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoPaginationSplitter.java x: 1 # contributors y: 85 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSampleSplitter.java x: 2 # contributors y: 95 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitVectorSplitter.java x: 2 # contributors y: 68 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitters.java x: 2 # contributors y: 48 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/PartitionStrategy.java x: 2 # contributors y: 40 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoConnectorOptions.java x: 4 # contributors y: 117 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/config/MongoConfiguration.java x: 3 # contributors y: 104 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoDynamicTableSource.java x: 3 # contributors y: 229 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoValidationUtils.java x: 2 # contributors y: 75 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoPrimaryKeyExtractor.java x: 1 # contributors y: 101 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoShardKeysExtractor.java x: 1 # contributors y: 75 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization/MongoRowDataSerializationSchema.java x: 2 # contributors y: 63 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/MongoSource.java x: 2 # contributors y: 115 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoScanSourceSplitReader.java x: 2 # contributors y: 165 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/MongoFilterPushDownVisitor.java x: 1 # contributors y: 204 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/split/MongoSourceSplitReader.java x: 2 # contributors y: 8 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoScanSourceSplit.java x: 2 # contributors y: 100 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumerator.java x: 2 # contributors y: 90 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/MongoWriter.java x: 2 # contributors y: 196 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context/DefaultMongoSinkContext.java x: 2 # contributors y: 25 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/context/MongoSinkContext.java x: 2 # contributors y: 11 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReader.java x: 2 # contributors y: 61 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoScanSourceSplitState.java x: 1 # contributors y: 27 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplitSerializer.java x: 2 # contributors y: 70 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/config/MongoConnectionOptions.java x: 1 # contributors y: 69 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoSerdeUtils.java x: 1 # contributors y: 62 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/common/utils/MongoUtils.java x: 1 # contributors y: 109 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/MongoSink.java x: 1 # contributors y: 42 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/config/MongoWriteOptions.java x: 1 # contributors y: 119 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/sink/writer/serializer/MongoSerializationSchema.java x: 1 # contributors y: 18 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumState.java x: 1 # contributors y: 48 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/MongoSourceEnumStateSerializer.java x: 1 # contributors y: 80 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/assigner/MongoScanSplitAssigner.java x: 1 # contributors y: 107 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoShardedSplitter.java x: 1 # contributors y: 72 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/enumerator/splitter/MongoSplitContext.java x: 1 # contributors y: 86 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/MongoSourceReaderContext.java x: 1 # contributors y: 59 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/reader/deserializer/MongoDeserializationSchema.java x: 1 # contributors y: 17 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/source/split/MongoSourceSplit.java x: 1 # contributors y: 31 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/BsonToRowDataConverters.java x: 1 # contributors y: 364 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/converter/RowDataToBsonConverters.java x: 1 # contributors y: 273 lines of code flink-connector-mongodb/src/main/java/org/apache/flink/connector/mongodb/table/serialization/MongoRowDataDeserializationSchema.java x: 1 # contributors y: 25 lines of code
364.0
lines of code
  min: 8.0
  average: 86.89
  25th percentile: 36.5
  median: 72.0
  75th percentile: 112.0
  max: 364.0
0 4.0
# contributors
min: 1.0 | average: 1.62 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 2.0 | max: 4.0