apache / flink-cdc - 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: 924
Daily file updates (only one update per file and date counted): 4335
First update: 2020-07-17
Latest update: 2025-04-29
Days between first and latest update: 1,748 (249 weeks, estimated 1,245 working days)
Active days (at least one file change): 553
Data:

Organized per file

File Change History Overall

File Age Distribution Overall

Days since first update

There are 924 files with 103,304 lines of code in files.

707 files that are 366+ days old (84,693 lines of code)
70 files that are 181-365 days old (4,910 lines of code)
112 files that are 91-180 days old (11,065 lines of code)
8 files that are 31-90 days old (519 lines of code)
27 files that are 1-30 days old (2,117 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 924 files with 103,304 lines of code in files.

414 files have been last changed 366+ days ago (34,745 lines of code)
96 files have been last changed 181-365 days ago (9,329 lines of code)
211 files have been last changed 91-180 days ago (25,035 lines of code)
87 files have been last changed 31-90 days ago (12,441 lines of code)
116 files have been last changed 1-30 days ago (21,754 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, md, sql, xml, html, properties, yaml, scala, js, sh, rb, txt, toml, json, css, gitignore, scss, c, svg, 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
suppressions.xml in tools/maven	11	-	2021-02-27	2025-03-26	10	6	jark@apache.org	34335406+yuxiqian@users.nor...
MySqlStreamingChangeEventSource.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql	1193	43	2023-11-03	2024-04-10	3	3	leonard@apache.org	nsk93@hotmail.com
AbstractLogMinerEventProcessor.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/processor	820	33	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
PostgresReplicationConnection.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection	749	34	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
LogMinerStreamingChangeEventSource.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer	729	29	2023-11-03	2024-11-08	5	5	leonard@apache.org	676366545@qq.com
PostgresConnection.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection	620	31	2023-11-03	2024-01-26	4	2	leonard@apache.org	125648852+loserwang1024@use...
MySqlConnection.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql	571	46	2023-11-03	2024-05-27	3	3	leonard@apache.org	hx0698@gmail.com
SqlServerStreamingChangeEventSource.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/io/debezium/connector/sqlserver	504	7	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
PostgresStreamingChangeEventSource.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql	392	12	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
LogMinerAdapter.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer	363	18	2023-11-03	2024-03-04	3	3	leonard@apache.org	ruanhang1993@hotmail.com
MySqlDefaultValueConverter.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql	352	17	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
RelationalChangeRecordEmitter.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational	223	10	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
CDCClient.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc	200	13	2023-11-03	2024-03-04	3	3	leonard@apache.org	ruanhang1993@hotmail.com
RegionCDCClient.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc	193	15	2023-11-03	2024-03-04	3	3	leonard@apache.org	ruanhang1993@hotmail.com
ChannelFactory.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/common/util	153	7	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
HistorizedRelationalDatabaseConnectorConfig.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational	134	4	2023-11-03	2023-11-03	1	1	leonard@apache.org	leonard@apache.org
PostgresObjectUtils.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql	108	5	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
TableMapEventDataDeserializer.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization	106	3	2023-11-03	2024-12-17	4	4	leonard@apache.org	34335406+yuxiqian@users.nor...
Lsn.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection	88	13	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
DefaultValueParserListener.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/antlr/listener	83	5	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
LogMinerChangeRecordEmitter.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer	80	5	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
ScanIterator.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/common/operation/iterator	79	1	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
CDCEvent.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc	55	6	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
GtidUtils.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql	55	3	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
ColumnType.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization	55	4	2023-11-03	2024-12-17	3	3	leonard@apache.org	34335406+yuxiqian@users.nor...
Utils.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql	51	3	2023-11-03	2024-03-06	3	2	leonard@apache.org	ruanhang1993@hotmail.com
BufferedSocketInputStream.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/io	46	5	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
EmbeddedEngineChangeEvent.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/embedded	44	7	2023-11-03	2024-03-06	2	2	leonard@apache.org	ruanhang1993@hotmail.com
ErrorMessageUtils.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/util	33	1	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
flink-cdc.yaml in flink-cdc-dist/src/main/flink-cdc-bin/conf	2	-	2023-12-01	2024-03-04	3	3	gongzhongqiang@apache.org	ruanhang1993@hotmail.com
MySqlValueConverters.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql	714	34	2023-12-04	2024-01-26	2	2	jiabao.sun@xtransfer.cn	125648852+loserwang1024@use...
TableMapEventMetadataDeserializer.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization	178	11	2023-12-05	2024-03-04	2	2	qidian990107@163.com	ruanhang1993@hotmail.com
Db2Connection.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2	413	27	2023-12-13	2024-05-06	2	1	genzhedangdang@gmail.com	genzhedangdang@gmail.com
Db2StreamingChangeEventSource.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2	398	7	2023-12-13	2023-12-13	1	1	genzhedangdang@gmail.com	genzhedangdang@gmail.com
Db2Utils.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/utils	334	21	2023-12-13	2024-08-02	2	2	genzhedangdang@gmail.com	125648852+loserwang1024@use...
Db2TableSource.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table	289	9	2023-12-13	2025-03-12	5	5	genzhedangdang@gmail.com	1365976815@qq.com
Db2ScanFetchTask.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch	282	15	2023-12-13	2025-01-14	2	2	genzhedangdang@gmail.com	125648852+loserwang1024@use...
Db2SourceFetchTaskContext.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch	251	25	2023-12-13	2025-01-14	3	3	genzhedangdang@gmail.com	125648852+loserwang1024@use...
Db2TableSourceFactory.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table	227	6	2023-12-13	2025-03-12	5	5	genzhedangdang@gmail.com	1365976815@qq.com
Db2StreamFetchTask.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch	134	10	2023-12-13	2025-01-14	2	2	genzhedangdang@gmail.com	125648852+loserwang1024@use...
Db2Dialect.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/dialect	131	14	2023-12-13	2024-12-17	2	2	genzhedangdang@gmail.com	125648852+loserwang1024@use...
Db2SourceBuilder.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source	128	26	2023-12-13	2025-03-06	4	4	genzhedangdang@gmail.com	xbjtdcq@gmail.com
Db2Source.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2	90	11	2023-12-13	2024-03-06	2	2	genzhedangdang@gmail.com	ruanhang1993@hotmail.com
Db2SourceConfigFactory.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/config	71	1	2023-12-13	2025-03-06	3	3	genzhedangdang@gmail.com	xbjtdcq@gmail.com
Db2SourceConfig.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/config	67	2	2023-12-13	2025-03-06	3	3	genzhedangdang@gmail.com	xbjtdcq@gmail.com
LsnOffset.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/offset	64	4	2023-12-13	2023-12-13	1	1	genzhedangdang@gmail.com	genzhedangdang@gmail.com
Db2ConnectionUtils.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/utils	57	2	2023-12-13	2024-04-23	2	2	genzhedangdang@gmail.com	@users.noreply.github.com
Db2TypeUtils.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/utils	54	2	2023-12-13	2024-04-23	2	2	genzhedangdang@gmail.com	@users.noreply.github.com
Db2Schema.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/dialect	49	3	2023-12-13	2023-12-13	1	1	genzhedangdang@gmail.com	genzhedangdang@gmail.com
Db2ChunkSplitter.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/dialect	42	4	2023-12-13	2024-12-17	4	3	genzhedangdang@gmail.com	125648852+loserwang1024@use...

Files Not Recently Changed (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
HistorizedRelationalDatabaseConnectorConfig.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational	134	4	2023-11-03	2023-11-03	1	1	leonard@apache.org	leonard@apache.org
Db2PooledDataSourceFactory.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/dialect	13	1	2023-12-13	2023-12-13	1	1	genzhedangdang@gmail.com	genzhedangdang@gmail.com
LsnFactory.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/offset	41	6	2023-12-13	2023-12-13	1	1	genzhedangdang@gmail.com	genzhedangdang@gmail.com
Db2Schema.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/dialect	49	3	2023-12-13	2023-12-13	1	1	genzhedangdang@gmail.com	genzhedangdang@gmail.com
LsnOffset.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/offset	64	4	2023-12-13	2023-12-13	1	1	genzhedangdang@gmail.com	genzhedangdang@gmail.com
Db2StreamingChangeEventSource.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2	398	7	2023-12-13	2023-12-13	1	1	genzhedangdang@gmail.com	genzhedangdang@gmail.com
LogMinerChangeRecordEmitter.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer	80	5	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
DefaultValueParserListener.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/antlr/listener	83	5	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
Lsn.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection	88	13	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
RelationalChangeRecordEmitter.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational	223	10	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
MySqlDefaultValueConverter.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql	352	17	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
PostgresStreamingChangeEventSource.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql	392	12	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
SqlServerStreamingChangeEventSource.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/io/debezium/connector/sqlserver	504	7	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
PostgresConnection.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection	620	31	2023-11-03	2024-01-26	4	2	leonard@apache.org	125648852+loserwang1024@use...
MySqlValueConverters.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql	714	34	2023-12-04	2024-01-26	2	2	jiabao.sun@xtransfer.cn	125648852+loserwang1024@use...
PostgresReplicationConnection.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection	749	34	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
AbstractLogMinerEventProcessor.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/processor	820	33	2023-11-03	2024-01-26	2	2	leonard@apache.org	125648852+loserwang1024@use...
flink-cdc.yaml in flink-cdc-dist/src/main/flink-cdc-bin/conf	2	-	2023-12-01	2024-03-04	3	3	gongzhongqiang@apache.org	ruanhang1993@hotmail.com
ErrorMessageUtils.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/util	33	1	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
BufferedSocketInputStream.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/io	46	5	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
GtidUtils.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql	55	3	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
CDCEvent.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc	55	6	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
ScanIterator.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/common/operation/iterator	79	1	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
PostgresObjectUtils.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql	108	5	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
ChannelFactory.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/common/util	153	7	2023-11-03	2024-03-04	2	2	leonard@apache.org	ruanhang1993@hotmail.com
TableMapEventMetadataDeserializer.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization	178	11	2023-12-05	2024-03-04	2	2	qidian990107@163.com	ruanhang1993@hotmail.com
RegionCDCClient.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc	193	15	2023-11-03	2024-03-04	3	3	leonard@apache.org	ruanhang1993@hotmail.com
CDCClient.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc	200	13	2023-11-03	2024-03-04	3	3	leonard@apache.org	ruanhang1993@hotmail.com
LogMinerAdapter.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer	363	18	2023-11-03	2024-03-04	3	3	leonard@apache.org	ruanhang1993@hotmail.com
DummyDocs.java in flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase	2	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
DummyDocs.java in flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2	2	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
DummyDocs.java in flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql	2	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
DummyDocs.java in flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver	2	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
DummyDocs.java in flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres	2	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
DummyDocs.java in flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle	2	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
DummyDocs.java in flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess	2	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
DummyDocs.java in flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb	2	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
DummyDocs.java in flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb	2	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
InlineElement.java in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description	4	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
BlockElement.java in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description	4	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
Event.java in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event	4	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
PendingSplitsState.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state	5	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
StartupMode.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table	5	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
PendingSplitsState.java in flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state	5	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
PipelineComposer.java in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer	5	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
SchemaOutOfSyncException.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/context/e...	6	1	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
DescriptionElement.java in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description	6	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
EventSourceProvider.java in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source	6	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
EventSinkProvider.java in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink	6	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com
ChangeEvent.java in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event	6	-	2024-03-06	2024-03-06	1	1	ruanhang1993@hotmail.com	ruanhang1993@hotmail.com

Most Recently Created Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
PostgresConnectionUtils.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection	47	1	2025-04-25	2025-04-25	1	1	vinh.pham@shopback.com	vinh.pham@shopback.com
RelationalTableFilters.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational	104	7	2025-04-24	2025-04-24	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
PostTransformOperatorBuilder.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	66	5	2025-04-23	2025-04-23	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
PreTransformOperatorBuilder.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	61	5	2025-04-23	2025-04-23	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
TransformContext.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	45	1	2025-04-23	2025-04-23	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
BatchDataSinkWriterOperator.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink	141	15	2025-04-22	2025-04-22	1	1	809097465@qq.com	809097465@qq.com
BatchSchemaOperator.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular	134	8	2025-04-22	2025-04-22	1	1	809097465@qq.com	809097465@qq.com
BatchRegularPrePartitionOperator.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning	93	8	2025-04-22	2025-04-22	1	1	809097465@qq.com	809097465@qq.com
DorisSchemaUtils.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/utils	90	5	2025-04-22	2025-04-22	1	1	37775475+qg-lin@users.norep...	37775475+qg-lin@users.norep...
BatchDataSinkFunctionOperator.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink	24	2	2025-04-22	2025-04-22	1	1	809097465@qq.com	809097465@qq.com
RuntimeExecutionMode.java in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline	7	-	2025-04-22	2025-04-22	1	1	809097465@qq.com	809097465@qq.com
IcebergMetadataApplier.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink	244	13	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
IcebergTypeUtils.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils	169	2	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
IcebergWriter.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2	143	8	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
IcebergSink.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2	121	9	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
CompactionOperator.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/...	115	6	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
IcebergCommitter.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2	115	6	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
IcebergDataSinkFactory.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink	92	3	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
IcebergDataSinkOptions.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink	49	-	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
CompactionOptions.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/...	48	12	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
IcebergDataSink.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink	44	3	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
WriteResultWrapper.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2	41	4	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
RowDataUtils.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils	38	1	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
WriteResultWrapperSerializer.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2	37	2	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
TableSchemaWrapper.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2	20	3	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
OptionUtils.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils	16	2	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
TableMetric.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2	13	2	2025-04-21	2025-04-21	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
DebeziumJsonRowDataSerializationSchema.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium	106	4	2025-04-07	2025-04-07	1	1	18814118038@163.com	18814118038@163.com
DebeziumJsonStruct.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium	53	6	2025-04-07	2025-04-07	1	1	18814118038@163.com	18814118038@163.com
YarnApplicationDeploymentExecutor.java in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment	122	1	2025-03-27	2025-04-29	2	2	18814118038@163.com	149778446+joycurry30@users....
BinaryRecordDataExtractor.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils	104	2	2025-03-27	2025-03-27	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
TransformException.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/exceptions	68	3	2025-03-27	2025-03-27	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
ComposeDeployment.java in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment	36	3	2025-03-27	2025-03-27	1	1	18814118038@163.com	18814118038@163.com
SinkWrapperException.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/exception	7	1	2025-03-27	2025-03-27	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
TimestampTypeMetadataColumn.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source	23	4	2025-03-11	2025-03-11	1	1	hx0698@gmail.com	hx0698@gmail.com
SqlServerOffsetContext.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/io/debezium/connector/sqlserver	192	21	2025-01-21	2025-01-21	1	1	gongzhongqiang@apache.org	gongzhongqiang@apache.org
KafkaSinkUtils.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/utils	27	1	2025-01-16	2025-01-16	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
download_libs.rb in tools/cdcup/src	97	5	2025-01-14	2025-01-14	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
app.rb in tools/cdcup/src	87	-	2025-01-14	2025-03-05	2	2	34335406+yuxiqian@users.nor...	fcsaky@apache.org
StarRocksEnrichedCatalog.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink	75	6	2025-01-14	2025-01-14	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
CDCPostgresDispatcher.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch	60	2	2025-01-14	2025-01-14	1	1	125648852+loserwang1024@use...	125648852+loserwang1024@use...
kafka.rb in tools/cdcup/src/sink	38	3	2025-01-14	2025-01-14	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
my_sql.rb in tools/cdcup/src/source	31	3	2025-01-14	2025-01-14	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
doris.rb in tools/cdcup/src/sink	27	3	2025-01-14	2025-01-14	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
star_rocks.rb in tools/cdcup/src/sink	25	3	2025-01-14	2025-01-14	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
DorisSchemaChangeManager.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink	23	3	2025-01-14	2025-04-07	3	3	34335406+yuxiqian@users.nor...	2795267041@qq.com
CompressAlgorithm.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/op...	19	2	2025-01-14	2025-01-14	1	1	72908278+chaomingzhangcn@us...	72908278+chaomingzhangcn@us...
paimon.rb in tools/cdcup/src/sink	15	2	2025-01-14	2025-01-14	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
WatermarkDispatcher.java in flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base	15	-	2025-01-14	2025-01-14	1	1	125648852+loserwang1024@use...	125648852+loserwang1024@use...
values_source.rb in tools/cdcup/src/source	14	2	2025-01-14	2025-01-14	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...

Most Recently Changed Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
SchemaCoordinator.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular	367	15	2024-12-23	2025-04-29	4	2	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
Schema.java in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema	291	38	2023-12-28	2025-04-29	7	6	decq12ybhl@gmail.com	34335406+yuxiqian@users.nor...
SchemaOperator.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular	185	12	2024-12-23	2025-04-29	6	4	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
YarnApplicationDeploymentExecutor.java in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment	122	1	2025-03-27	2025-04-29	2	2	18814118038@163.com	149778446+joycurry30@users....
SystemFunctionUtils.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions	902	121	2024-03-20	2025-04-25	11	5	32723967+wenmo@users.norepl...	34335406+yuxiqian@users.nor...
JaninoCompiler.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser	544	5	2024-03-20	2025-04-25	12	5	32723967+wenmo@users.norepl...	34335406+yuxiqian@users.nor...
SnapshotSplitReader.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader	381	25	2024-03-06	2025-04-25	3	3	ruanhang1993@hotmail.com	125648852+loserwang1024@use...
PostgresScanFetchTask.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch	309	13	2024-03-06	2025-04-25	4	3	ruanhang1993@hotmail.com	125648852+loserwang1024@use...
PostgreSQLTableFactory.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table	237	6	2024-03-06	2025-04-25	6	6	ruanhang1993@hotmail.com	vinh.pham@shopback.com
IncrementalSourceSplitReader.java in flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader	234	17	2024-03-06	2025-04-25	2	2	ruanhang1993@hotmail.com	125648852+loserwang1024@use...
MySqlSplitReader.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader	205	14	2024-03-06	2025-04-25	3	3	ruanhang1993@hotmail.com	125648852+loserwang1024@use...
PostgresDialect.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source	200	21	2024-03-06	2025-04-25	6	5	ruanhang1993@hotmail.com	vinh.pham@shopback.com
StreamSplitAssigner.java in flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner	156	17	2024-03-06	2025-04-25	5	5	ruanhang1993@hotmail.com	vinh.pham@shopback.com
JdbcSourceConfigFactory.java in flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config	147	23	2024-03-06	2025-04-25	5	5	ruanhang1993@hotmail.com	vinh.pham@shopback.com
StartupOptions.java in flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options	89	12	2024-03-06	2025-04-25	2	2	ruanhang1993@hotmail.com	vinh.pham@shopback.com
MySqlRecords.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split	53	6	2024-03-06	2025-04-25	2	2	ruanhang1993@hotmail.com	125648852+loserwang1024@use...
PostgresConnectionUtils.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection	47	1	2025-04-25	2025-04-25	1	1	vinh.pham@shopback.com	vinh.pham@shopback.com
DataSourceDialect.java in flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/dialect	35	3	2024-03-06	2025-04-25	4	3	ruanhang1993@hotmail.com	vinh.pham@shopback.com
StartupMode.java in flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options	10	-	2024-03-06	2025-04-25	2	2	ruanhang1993@hotmail.com	vinh.pham@shopback.com
IncrementalSourceReader.java in flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader	431	20	2024-03-06	2025-04-24	3	3	ruanhang1993@hotmail.com	genzhedangdang@gmail.com
SchemaRegistry.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common	285	21	2024-12-23	2025-04-24	3	4	34335406+yuxiqian@users.nor...	lvyanquan.lyq@alibaba-inc.com
MySqlSourceConfig.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config	226	32	2024-03-06	2025-04-24	8	8	ruanhang1993@hotmail.com	lvyanquan.lyq@alibaba-inc.com
RelationalTableFilters.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational	104	7	2025-04-24	2025-04-24	1	1	lvyanquan.lyq@alibaba-inc.com	lvyanquan.lyq@alibaba-inc.com
DebeziumOptions.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table	30	2	2024-03-06	2025-04-24	2	2	ruanhang1993@hotmail.com	lvyanquan.lyq@alibaba-inc.com
SchemaMergingUtils.java in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils	818	26	2024-12-23	2025-04-23	3	2	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
TransformParser.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser	512	19	2024-03-20	2025-04-23	17	8	32723967+wenmo@users.norepl...	34335406+yuxiqian@users.nor...
SchemaUtils.java in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils	488	18	2024-03-06	2025-04-23	12	4	ruanhang1993@hotmail.com	34335406+yuxiqian@users.nor...
PostTransformOperator.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	398	18	2024-08-08	2025-04-23	15	5	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
PreTransformOperator.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	390	18	2024-08-08	2025-04-23	15	4	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
FlinkPipelineComposer.java in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink	194	8	2024-03-06	2025-04-23	18	11	ruanhang1993@hotmail.com	34335406+yuxiqian@users.nor...
DataChangeEvent.java in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event	183	24	2024-03-06	2025-04-23	5	3	ruanhang1993@hotmail.com	34335406+yuxiqian@users.nor...
TransformFilterProcessor.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	168	5	2024-03-20	2025-04-23	8	5	32723967+wenmo@users.norepl...	34335406+yuxiqian@users.nor...
UserDefinedFunctionDescriptor.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	134	13	2024-08-09	2025-04-23	3	2	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
ProjectionColumnProcessor.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	133	4	2024-03-20	2025-04-23	10	5	32723967+wenmo@users.norepl...	34335406+yuxiqian@users.nor...
TransformTranslator.java in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator	111	3	2024-03-20	2025-04-23	12	7	32723967+wenmo@users.norepl...	34335406+yuxiqian@users.nor...
PostTransformChangeInfo.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	95	10	2024-08-08	2025-04-23	2	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
TransformProjectionProcessor.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	73	2	2024-03-20	2025-04-23	7	4	32723967+wenmo@users.norepl...	34335406+yuxiqian@users.nor...
TransformFilter.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	72	9	2024-03-20	2025-04-23	5	3	32723967+wenmo@users.norepl...	34335406+yuxiqian@users.nor...
PostTransformOperatorBuilder.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	66	5	2025-04-23	2025-04-23	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
PreTransformOperatorBuilder.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	61	5	2025-04-23	2025-04-23	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
TransformRule.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	61	8	2024-08-08	2025-04-23	5	3	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
TransformContext.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	45	1	2025-04-23	2025-04-23	1	1	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
PostTransformer.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	40	5	2024-08-08	2025-04-23	4	2	34335406+yuxiqian@users.nor...	34335406+yuxiqian@users.nor...
TransformProjection.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform	40	6	2024-03-20	2025-04-23	3	3	32723967+wenmo@users.norepl...	34335406+yuxiqian@users.nor...
ValuesDataSourceHelper.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source	937	5	2024-03-06	2025-04-22	7	6	ruanhang1993@hotmail.com	809097465@qq.com
MySqlDataSourceFactory.java in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory	461	14	2024-03-06	2025-04-22	18	11	ruanhang1993@hotmail.com	809097465@qq.com
JdbcSourceChunkSplitter.java in flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter	398	24	2024-03-06	2025-04-22	10	8	ruanhang1993@hotmail.com	131222468+linjianchang@user...
MongoDBTableSource.java in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table	353	9	2024-03-06	2025-04-22	5	5	ruanhang1993@hotmail.com	hrunker@gmail.com
SchemaDerivator.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common	321	14	2024-12-23	2025-04-22	3	3	34335406+yuxiqian@users.nor...	809097465@qq.com
SchemaManager.java in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common	290	26	2024-12-23	2025-04-22	2	2	34335406+yuxiqian@users.nor...	809097465@qq.com