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

Number of files: 54
Daily file updates (only one update per file and date counted): 114
First update: 2022-11-29
Latest update: 2025-03-17
Days between first and latest update: 840 (120 weeks, estimated 600 working days)
Active days (at least one file change): 40
Files without commit history (ignored): 1 (6 lines of code)

Files without history

Data:

Organized per file

File Change History Overall

File Age Distribution Overall

Days since first update

There are 53 files with 4,605 lines of code in files.

49 files that are 366+ days old (4,320 lines of code)
3 files that are 181-365 days old (200 lines of code)
1 files that are 91-180 days old (85 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)

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 53 files with 4,605 lines of code in files.

35 files have been last changed 366+ days ago (2,996 lines of code)
5 files have been last changed 181-365 days ago (543 lines of code)
12 files have been last changed 91-180 days ago (1,042 lines of code)
1 files have been last changed 31-90 days ago (24 lines of code)
0 files have been last changed 1-30 days ago (0 lines of code)

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, yaml, properties, sql, gitignore, txt, editorconfig, gitmodules

File Age Distribution per Extension

Days since first update

366+

181-365

91-180

31-90

1-30

File Freshness Distribution per Extension

Days since last update

366+

181-365

91-180

31-90

1-30

File Change History per Logical Decomposition

primary

primary (file age distribution)

Days since first update

366+

181-365

91-180

31-90

1-30

primary (file freshness distribution)

Days since last update

366+

181-365

91-180

31-90

1-30

Oldest Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first 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
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
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
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...
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
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
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...
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
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
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...
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
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	2024-07-16	2	2	328226527@qq.com	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
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	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
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
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
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...
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
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...
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
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
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
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...
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
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
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
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
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

Files Not Recently Changed (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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...
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...
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...
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...
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...
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...
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...
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...
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

Most Recently Created Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
suppressions.xml in tools/maven	6	-
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...
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
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
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
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
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
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
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
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...
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
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
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...
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
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
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...
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
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	2024-07-16	2	2	328226527@qq.com	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
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	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
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
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
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...
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
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...
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
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
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
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...
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

Most Recently Changed Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
suppressions.xml in tools/maven	6	-
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
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...
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
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...
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...
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...
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...
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...
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...
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...
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...
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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