apache / flink-cdc
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 924 files with 103,304 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)
    • 52 files changed 6-20 times (14,358 lines of code)
    • 872 files changed 1-5 times (88,946 lines of code)
0% | 0% | 0% | 13% | 86%
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 924 files with 103,304 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 2 files changed by 11-25 contributors (655 lines of code)
    • 24 files changed by 6-10 contributors (6,852 lines of code)
    • 347 files changed by 2-5 contributors (58,389 lines of code)
    • 551 files changed by 1 contributor (37,408 lines of code)
0% | <1% | 6% | 56% | 36%
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, md, sql, xml, html, properties, yaml, scala, js, sh, rb, txt, toml, json, css, gitignore, scss, c, svg, gitmodules
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 13% | 86%
xml0% | 0% | 0% | 100% | 0%
rb0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
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-cdc-connect0% | 0% | 0% | 11% | 88%
flink-cdc-runtime0% | 0% | 0% | 24% | 75%
flink-cdc-composer0% | 0% | 0% | 52% | 47%
flink-cdc-common0% | 0% | 0% | 7% | 92%
flink-cdc-cli0% | 0% | 0% | 58% | 41%
tools0% | 0% | 0% | 2% | 97%
flink-cdc-pipeline-model0% | 0% | 0% | 0% | 100%
flink-cdc-dist0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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...
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
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...
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...
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...
MySqlDataSourceOptions.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source
 267 - 2024-03-06 2025-03-12 13 10 ruanhang1993@hotmail.com 1365976815@qq.com
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...
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...
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...
YamlPipelineDefinitionParser.java
in flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser
 286 11 2024-03-06 2025-03-27 11 7 ruanhang1993@hotmail.com 18814118038@163.com
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...
suppressions.xml
in tools/maven
 11 - 2021-02-27 2025-03-26 10 6 jark@apache.org 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...
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...
SchemaOperatorTranslator.java
in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator
 159 8 2024-03-06 2025-04-22 9 6 ruanhang1993@hotmail.com 809097465@qq.com
DorisMetadataApplier.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink
 273 15 2023-12-28 2025-04-22 9 5 decq12ybhl@gmail.com 37775475+qg-lin@users.norep...
PaimonMetadataApplier.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink
 316 18 2024-04-24 2025-03-05 9 8 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com
MySqlTableSource.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table
 385 11 2024-03-06 2025-04-17 9 8 ruanhang1993@hotmail.com hrunker@gmail.com
KafkaDataSinkFactory.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink
 109 2 2024-04-23 2025-04-09 8 5 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com
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...
PaimonWriter.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2
 171 6 2024-04-24 2025-04-03 8 2 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com
DataSinkTranslator.java
in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator
 179 8 2024-03-06 2025-04-22 8 5 ruanhang1993@hotmail.com 809097465@qq.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
MySqlSourceOptions.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config
 239 - 2024-03-06 2025-04-17 8 8 ruanhang1993@hotmail.com hrunker@gmail.com
BinlogSplitReader.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader
 303 16 2024-03-06 2025-03-05 8 7 ruanhang1993@hotmail.com hx0698@gmail.com
CustomAlterTableParserListener.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser
 380 24 2023-12-28 2025-01-17 8 6 decq12ybhl@gmail.com 37775475+qg-lin@users.norep...
MySqlSnapshotSplitAssigner.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners
 517 32 2024-03-06 2025-04-08 8 4 ruanhang1993@hotmail.com 125648852+loserwang1024@use...
SnapshotSplitAssigner.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner
 585 32 2024-03-06 2025-04-08 8 4 ruanhang1993@hotmail.com 125648852+loserwang1024@use...
DataSourceTranslator.java
in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator
 69 3 2024-03-06 2025-04-22 7 5 ruanhang1993@hotmail.com 809097465@qq.com
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...
OracleChunkSplitter.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/assigner/splitter
 132 9 2024-03-06 2025-04-22 7 6 ruanhang1993@hotmail.com 131222468+linjianchang@user...
CliFrontend.java
in flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli
 197 7 2024-03-06 2025-03-27 7 7 ruanhang1993@hotmail.com 18814118038@163.com
DataSinkWriterOperator.java
in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink
 207 16 2024-03-06 2025-03-27 7 5 ruanhang1993@hotmail.com 34335406+yuxiqian@users.nor...
MySqlPipelineRecordEmitter.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader
 231 10 2023-12-28 2025-04-22 7 7 decq12ybhl@gmail.com 809097465@qq.com
MySqlSourceConfigFactory.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config
 253 33 2024-03-06 2025-03-06 7 7 ruanhang1993@hotmail.com xbjtdcq@gmail.com
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...
MySqlTableSourceFactory.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table
 334 13 2024-03-06 2025-04-17 7 7 ruanhang1993@hotmail.com hrunker@gmail.com
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
FlinkEnvironmentUtils.java
in flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils
 29 1 2024-03-06 2025-03-27 6 5 ruanhang1993@hotmail.com 18814118038@163.com
SqlServerChunkSplitter.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/dialect
 50 6 2024-03-06 2025-04-22 6 5 ruanhang1993@hotmail.com 131222468+linjianchang@user...
ConfigurationUtils.java
in flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils
 51 4 2024-03-06 2025-03-27 6 5 ruanhang1993@hotmail.com 18814118038@163.com
PartitioningTranslator.java
in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator
 73 3 2024-03-06 2025-04-22 6 6 ruanhang1993@hotmail.com 809097465@qq.com
PipelineOptions.java
in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline
 76 1 2024-03-06 2025-04-22 6 4 ruanhang1993@hotmail.com 809097465@qq.com
PipelineDef.java
in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition
 143 15 2024-03-06 2025-04-22 6 4 ruanhang1993@hotmail.com 809097465@qq.com
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...
CanalJsonSerializationSchema.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/canal
 190 3 2024-04-23 2025-01-13 6 3 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com
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
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
PostgresSourceBuilder.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source
 265 34 2024-03-06 2025-03-06 6 6 ruanhang1993@hotmail.com xbjtdcq@gmail.com
TransformSqlOperatorTable.java
in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/metadata
 309 4 2024-03-20 2025-01-13 6 6 32723967+wenmo@users.norepl... 809097465@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
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...
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
MySqlDataSourceOptions.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source
 267 - 2024-03-06 2025-03-12 13 10 ruanhang1993@hotmail.com 1365976815@qq.com
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...
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...
PaimonMetadataApplier.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink
 316 18 2024-04-24 2025-03-05 9 8 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com
MySqlTableSource.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table
 385 11 2024-03-06 2025-04-17 9 8 ruanhang1993@hotmail.com hrunker@gmail.com
MySqlSourceOptions.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config
 239 - 2024-03-06 2025-04-17 8 8 ruanhang1993@hotmail.com hrunker@gmail.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
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...
YamlPipelineDefinitionParser.java
in flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser
 286 11 2024-03-06 2025-03-27 11 7 ruanhang1993@hotmail.com 18814118038@163.com
BinlogSplitReader.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader
 303 16 2024-03-06 2025-03-05 8 7 ruanhang1993@hotmail.com hx0698@gmail.com
CliFrontend.java
in flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli
 197 7 2024-03-06 2025-03-27 7 7 ruanhang1993@hotmail.com 18814118038@163.com
MySqlPipelineRecordEmitter.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader
 231 10 2023-12-28 2025-04-22 7 7 decq12ybhl@gmail.com 809097465@qq.com
MySqlTableSourceFactory.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table
 334 13 2024-03-06 2025-04-17 7 7 ruanhang1993@hotmail.com hrunker@gmail.com
MySqlSourceConfigFactory.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config
 253 33 2024-03-06 2025-03-06 7 7 ruanhang1993@hotmail.com xbjtdcq@gmail.com
suppressions.xml
in tools/maven
 11 - 2021-02-27 2025-03-26 10 6 jark@apache.org 34335406+yuxiqian@users.nor...
SchemaOperatorTranslator.java
in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator
 159 8 2024-03-06 2025-04-22 9 6 ruanhang1993@hotmail.com 809097465@qq.com
CustomAlterTableParserListener.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser
 380 24 2023-12-28 2025-01-17 8 6 decq12ybhl@gmail.com 37775475+qg-lin@users.norep...
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...
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
OracleChunkSplitter.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/assigner/splitter
 132 9 2024-03-06 2025-04-22 7 6 ruanhang1993@hotmail.com 131222468+linjianchang@user...
PartitioningTranslator.java
in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator
 73 3 2024-03-06 2025-04-22 6 6 ruanhang1993@hotmail.com 809097465@qq.com
TransformSqlOperatorTable.java
in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/metadata
 309 4 2024-03-20 2025-01-13 6 6 32723967+wenmo@users.norepl... 809097465@qq.com
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
PostgresSourceBuilder.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source
 265 34 2024-03-06 2025-03-06 6 6 ruanhang1993@hotmail.com xbjtdcq@gmail.com
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...
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...
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...
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...
DorisMetadataApplier.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink
 273 15 2023-12-28 2025-04-22 9 5 decq12ybhl@gmail.com 37775475+qg-lin@users.norep...
DataSinkTranslator.java
in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator
 179 8 2024-03-06 2025-04-22 8 5 ruanhang1993@hotmail.com 809097465@qq.com
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...
KafkaDataSinkFactory.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink
 109 2 2024-04-23 2025-04-09 8 5 lvyanquan.lyq@alibaba-inc.com 18814118038@163.com
DataSourceTranslator.java
in flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator
 69 3 2024-03-06 2025-04-22 7 5 ruanhang1993@hotmail.com 809097465@qq.com
DataSinkWriterOperator.java
in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink
 207 16 2024-03-06 2025-03-27 7 5 ruanhang1993@hotmail.com 34335406+yuxiqian@users.nor...
ConfigurationUtils.java
in flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils
 51 4 2024-03-06 2025-03-27 6 5 ruanhang1993@hotmail.com 18814118038@163.com
FlinkEnvironmentUtils.java
in flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils
 29 1 2024-03-06 2025-03-27 6 5 ruanhang1993@hotmail.com 18814118038@163.com
SqlServerChunkSplitter.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/dialect
 50 6 2024-03-06 2025-04-22 6 5 ruanhang1993@hotmail.com 131222468+linjianchang@user...
MySqlChunkSplitter.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners
 378 21 2024-03-06 2025-04-08 6 5 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
CliExecutor.java
in flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli
 107 6 2024-03-06 2025-03-27 5 5 ruanhang1993@hotmail.com 18814118038@163.com
CliFrontendOptions.java
in flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli
 91 1 2024-03-06 2025-04-07 5 5 ruanhang1993@hotmail.com 56642952+lidoudou1993@users...
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
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
PendingSplitsStateSerializer.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state
 395 24 2024-03-06 2024-12-17 5 5 ruanhang1993@hotmail.com 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
OracleTableSourceFactory.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table
 204 6 2024-03-06 2025-03-12 5 5 ruanhang1993@hotmail.com 1365976815@qq.com
OracleTableSource.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table
 310 9 2024-03-06 2025-03-12 5 5 ruanhang1993@hotmail.com 1365976815@qq.com
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
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
MongoDBConnectorDeserializationSchema.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table
 678 33 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
BinaryStringData.java
in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary
 615 54 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
RowDataTiKVEventDeserializationSchemaBase.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table
 459 21 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
OceanBaseValueConverters.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/converter
 457 24 2024-04-25 2024-04-25 1 1 wanghechn@qq.com wanghechn@qq.com
TypeConvertUtils.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils
 447 6 2025-01-08 2025-01-08 1 1 50667759+dingxin-tech@users... 50667759+dingxin-tech@users...
BinaryArrayData.java
in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary
 433 54 2025-01-06 2025-01-06 1 1 umeshdangat@users.noreply.g... umeshdangat@users.noreply.g...
OceanBaseMySQLCatalog.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog
 417 18 2025-01-06 2025-01-06 1 1 zhao137578346@gmail.com zhao137578346@gmail.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
DebeziumSourceFunction.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium
 400 19 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.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
SchemaCoordinator.java
in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed
 362 14 2024-12-23 2025-04-21 2 1 34335406+yuxiqian@users.nor... 34335406+yuxiqian@users.nor...
TokenStream.java
in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text
 357 47 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
MongoDBConnectorSourceTask.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/internal
 280 16 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
OceanBaseConnection.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/connection
 268 14 2024-04-25 2024-04-25 1 1 wanghechn@qq.com wanghechn@qq.com
MongoDBSource.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb
 264 24 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
BsonUtils.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils
 258 17 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
MapDataSerializer.java
in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data
 257 25 2025-01-06 2025-01-06 1 1 umeshdangat@users.noreply.g... umeshdangat@users.noreply.g...
OceanBaseUtils.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink
 250 4 2025-01-06 2025-01-06 1 1 zhao137578346@gmail.com zhao137578346@gmail.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
JsonStringFormatter.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/json
 244 30 2024-10-22 2024-10-22 1 1 louis.sml@kakaocorp.com louis.sml@kakaocorp.com
SessionManageOperator.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/co...
 238 14 2025-01-08 2025-01-08 1 1 50667759+dingxin-tech@users... 50667759+dingxin-tech@users...
SessionManageCoordinator.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/co...
 232 17 2025-01-08 2025-01-08 1 1 50667759+dingxin-tech@users... 50667759+dingxin-tech@users...
GenericArrayData.java
in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data
 230 32 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
MaxComputeUtils.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils
 225 11 2025-01-08 2025-01-08 1 1 50667759+dingxin-tech@users... 50667759+dingxin-tech@users...
VitessTableSource.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table
 225 8 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
MySqlSplitSerializer.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split
 216 7 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
OracleDeserializationConverterFactory.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table
 212 11 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
SchemaEvolutionUtils.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils
 209 11 2025-01-08 2025-01-08 1 1 50667759+dingxin-tech@users... 50667759+dingxin-tech@users...
EnumSerializer.java
in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer
 201 24 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
CollectionDiscoveryUtils.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils
 198 23 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
StringUtf8Utils.java
in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils
 195 6 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
BinaryArrayWriter.java
in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer
 194 25 2025-01-06 2025-01-06 1 1 umeshdangat@users.noreply.g... umeshdangat@users.noreply.g...
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
LinkedListSerializer.java
in flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer
 190 22 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
SourceEnumeratorMetrics.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics
 189 22 2024-12-06 2024-12-06 1 1 754089893@qq.com 754089893@qq.com
InstantiationUtil.java
in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils
 185 13 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
DebeziumChangeFetcher.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal
 185 14 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
TemporalConversions.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/utils
 184 6 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
OceanBaseTable.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog
 179 19 2025-01-06 2025-01-06 1 1 zhao137578346@gmail.com zhao137578346@gmail.com
StoreSinkWriteImpl.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2
 178 15 2024-04-24 2025-01-09 4 1 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com
RowType.java
in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types
 174 29 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
MongoDBScanFetchTask.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch
 171 7 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.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
DebeziumSchemaDataTypeInference.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event
 169 14 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
FlinkJsonTableChangeSerializer.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/history
 166 7 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
VitessTableFactory.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/table
 165 2 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
DataTypes.java
in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types
 164 45 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
VitessSource.java
in flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess
 161 22 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
TableSchemaInfo.java
in flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json
 159 5 2024-04-23 2024-11-11 3 1 lvyanquan.lyq@alibaba-inc.com lvyanquan.lyq@alibaba-inc.com
DataTypeChecks.java
in flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types
 158 28 2024-03-06 2024-03-06 1 1 ruanhang1993@hotmail.com ruanhang1993@hotmail.com
Correlations

File Size vs. Number of Changes: 924 points

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/YarnApplicationDeploymentExecutor.java x: 122 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaCoordinator.java x: 367 lines of code y: 4 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaOperator.java x: 185 lines of code y: 6 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java x: 291 lines of code y: 7 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceSplitReader.java x: 234 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java x: 381 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSplitReader.java x: 205 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlRecords.java x: 53 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresScanFetchTask.java x: 309 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/JdbcSourceConfigFactory.java x: 147 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/dialect/DataSourceDialect.java x: 35 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupMode.java x: 10 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java x: 89 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/StreamSplitAssigner.java x: 156 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnectionUtils.java x: 47 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDialect.java x: 200 lines of code y: 6 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableFactory.java x: 237 lines of code y: 6 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/SystemFunctionUtils.java x: 902 lines of code y: 11 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/JaninoCompiler.java x: 544 lines of code y: 12 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceReader.java x: 431 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational/RelationalTableFilters.java x: 104 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/DebeziumOptions.java x: 30 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceConfig.java x: 226 lines of code y: 8 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaRegistry.java x: 285 lines of code y: 3 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DataChangeEvent.java x: 183 lines of code y: 5 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaMergingUtils.java x: 818 lines of code y: 3 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaUtils.java x: 488 lines of code y: 12 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposer.java x: 194 lines of code y: 18 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/TransformTranslator.java x: 111 lines of code y: 12 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformChangeInfo.java x: 95 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperator.java x: 398 lines of code y: 15 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperatorBuilder.java x: 66 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformer.java x: 40 lines of code y: 4 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperator.java x: 390 lines of code y: 15 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperatorBuilder.java x: 61 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/ProjectionColumnProcessor.java x: 133 lines of code y: 10 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformContext.java x: 45 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformFilter.java x: 72 lines of code y: 5 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformFilterProcessor.java x: 168 lines of code y: 8 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformProjection.java x: 40 lines of code y: 3 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformProjectionProcessor.java x: 73 lines of code y: 7 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformRule.java x: 61 lines of code y: 5 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java x: 134 lines of code y: 3 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/TransformParser.java x: 512 lines of code y: 17 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitSerializer.java x: 234 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/PendingSplitsStateSerializer.java x: 395 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceOptions.java x: 141 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java x: 353 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSourceFactory.java x: 208 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java x: 398 lines of code y: 10 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/assigner/splitter/OracleChunkSplitter.java x: 132 lines of code y: 7 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/dialect/SqlServerChunkSplitter.java x: 50 lines of code y: 6 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/factory/DorisDataSinkFactory.java x: 136 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisDataSink.java x: 54 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisDataSinkOptions.java x: 153 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisEventSerializer.java x: 129 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java x: 273 lines of code y: 9 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/utils/DorisSchemaUtils.java x: 90 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java x: 76 lines of code y: 6 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/RuntimeExecutionMode.java x: 7 lines of code y: 1 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java x: 143 lines of code y: 6 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslator.java x: 179 lines of code y: 8 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSourceTranslator.java x: 69 lines of code y: 7 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/PartitioningTranslator.java x: 73 lines of code y: 6 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/SchemaOperatorTranslator.java x: 159 lines of code y: 9 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java x: 461 lines of code y: 18 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlPipelineRecordEmitter.java x: 231 lines of code y: 7 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/factory/ValuesDataFactory.java x: 90 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/ValuesDataSourceHelper.java x: 937 lines of code y: 7 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/ValuesDataSourceOptions.java x: 41 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSource.java x: 209 lines of code y: 3 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaDerivator.java x: 321 lines of code y: 3 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java x: 290 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/TableIdRouter.java x: 86 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/BatchSchemaOperator.java x: 134 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/BatchDataSinkFunctionOperator.java x: 24 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/BatchDataSinkWriterOperator.java x: 141 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkWriterOperatorFactory.java x: 57 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/BatchRegularPrePartitionOperator.java x: 93 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed/SchemaCoordinator.java x: 362 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed/SchemaOperator.java x: 176 lines of code y: 4 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed/event/SchemaChangeRequest.java x: 46 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkFactory.java x: 92 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergDataSinkOptions.java x: 49 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergMetadataApplier.java x: 244 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/IcebergTypeUtils.java x: 169 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/OptionUtils.java x: 16 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/RowDataUtils.java x: 38 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergCommitter.java x: 115 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergSink.java x: 121 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergWriter.java x: 143 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/TableMetric.java x: 13 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/TableSchemaWrapper.java x: 20 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/WriteResultWrapper.java x: 41 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/JdbcChunkUtils.java x: 80 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/ChunkUtils.java x: 75 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/util/ChunkUtils.java x: 48 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java x: 529 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java x: 239 lines of code y: 8 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSource.java x: 385 lines of code y: 9 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactory.java x: 334 lines of code y: 7 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/ChangeLogJsonFormatFactory.java x: 66 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSinkFactory.java x: 109 lines of code y: 8 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSinkOptions.java x: 76 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/DebeziumEventDeserializationSchema.java x: 353 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java x: 585 lines of code y: 8 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlChunkSplitter.java x: 378 lines of code y: 6 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java x: 517 lines of code y: 8 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisSchemaChangeManager.java x: 23 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonRowDataSerializationSchema.java x: 106 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonSerializationSchema.java x: 343 lines of code y: 6 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonStruct.java x: 53 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/utils/JsonRowDataSerializationSchemaUtils.java x: 101 lines of code y: 2 # changes flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontendOptions.java x: 91 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriter.java x: 171 lines of code y: 8 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonEventSink.java x: 58 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/PostgresQueryUtils.java x: 318 lines of code y: 4 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkFunctionOperator.java x: 103 lines of code y: 5 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkWriterOperator.java x: 207 lines of code y: 7 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/ProjectionColumn.java x: 112 lines of code y: 5 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionCompiler.java x: 50 lines of code y: 5 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java x: 84 lines of code y: 3 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/exceptions/TransformException.java x: 68 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/factories/FactoryHelper.java x: 131 lines of code y: 3 # changes flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliExecutor.java x: 107 lines of code y: 5 # changes flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontend.java x: 197 lines of code y: 7 # changes flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/PipelineDefinitionParser.java x: 8 lines of code y: 3 # changes flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java x: 286 lines of code y: 11 # changes flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/FlinkEnvironmentUtils.java x: 29 lines of code y: 6 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/PipelineDeploymentExecutor.java x: 13 lines of code y: 2 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/ComposeDeployment.java x: 36 lines of code y: 1 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/K8SApplicationDeploymentExecutor.java x: 66 lines of code y: 2 # changes tools/maven/suppressions.xml x: 11 lines of code y: 10 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PreCommitOperator.java x: 98 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSourceReader.java x: 456 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlBinlogSplit.java x: 254 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresSourceReader.java x: 96 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSinkFactory.java x: 146 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSinkOptions.java x: 106 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java x: 267 lines of code y: 13 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/SourceOptions.java x: 116 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/Db2TableSource.java x: 289 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/Db2TableSourceFactory.java x: 227 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java x: 310 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSourceFactory.java x: 204 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java x: 346 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableFactory.java x: 229 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java x: 296 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/TimestampTypeMetadataColumn.java x: 23 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/ValuesDataSource.java x: 267 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonEvent.java x: 55 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonRecordEventSerializer.java x: 62 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriterHelper.java x: 293 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/JdbcSourceConfig.java x: 127 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/SourceConfig.java x: 19 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/Db2SourceBuilder.java x: 128 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/config/Db2SourceConfig.java x: 67 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/config/Db2SourceConfigFactory.java x: 71 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/MongoDBSourceBuilder.java x: 115 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SampleBucketSplitStrategy.java x: 118 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SplitVectorSplitStrategy.java x: 99 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java x: 212 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfigFactory.java x: 175 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSourceBuilder.java x: 133 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceConfigFactory.java x: 253 lines of code y: 7 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/OracleSourceBuilder.java x: 140 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/config/OracleSourceConfig.java x: 80 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/config/OracleSourceConfigFactory.java x: 89 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java x: 265 lines of code y: 6 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/config/PostgresSourceConfig.java x: 87 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/config/PostgresSourceConfigFactory.java x: 103 lines of code y: 4 # changes tools/cdcup/src/app.rb x: 87 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReader.java x: 303 lines of code y: 8 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java x: 316 lines of code y: 9 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/io/debezium/connector/sqlserver/SqlServerOffsetContext.java x: 192 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/offset/LsnFactory.java x: 40 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/offset/LsnOffset.java x: 63 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/HybridSplitAssigner.java x: 235 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/StreamSplit.java x: 247 lines of code y: 4 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/AbstractBinaryWriter.java x: 270 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/MySqlSnapshotSplitReadTask.java x: 319 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffset.java x: 183 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/config/ElasticsearchSinkOptions.java x: 113 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/serializer/ElasticsearchEventSerializer.java x: 208 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSink.java x: 108 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkFactory.java x: 159 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkOptions.java x: 74 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomAlterTableParserListener.java x: 380 lines of code y: 8 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/MySqlSource.java x: 150 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLReadableMetadata.java x: 98 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/PipelineKafkaRecordSerializationSchema.java x: 120 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/utils/KafkaSinkUtils.java x: 27 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/context/StatefulTaskContext.java x: 347 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisRowConverter.java x: 145 lines of code y: 2 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/MetadataApplier.java x: 26 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSource.java x: 73 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlEventDeserializer.java x: 152 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomMySqlAntlrDdlParser.java x: 260 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomMySqlAntlrDdlParserListener.java x: 92 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/utils/MySqlSchemaUtils.java x: 113 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/utils/MySqlTypeUtils.java x: 211 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/schema/MySqlTypeUtils.java x: 200 lines of code y: 2 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/TransformDef.java x: 111 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java x: 37 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/converters/MysqlDebeziumTimeConverter.java x: 282 lines of code y: 4 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/DateTimeUtils.java x: 181 lines of code y: 4 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/metadata/TransformSqlOperatorTable.java x: 309 lines of code y: 6 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/metadata/TransformSqlReturnTypes.java x: 134 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/DataTypeConverter.java x: 791 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch/Db2ScanFetchTask.java x: 282 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch/Db2SourceFetchTaskContext.java x: 251 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/EventProcessorFactory.java x: 244 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/OracleScanFetchTask.java x: 276 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/OracleSourceFetchTaskContext.java x: 264 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/OracleStreamFetchTask.java x: 127 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/CDCPostgresDispatcher.java x: 60 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresSourceFetchTaskContext.java x: 300 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresStreamFetchTask.java x: 188 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/reader/fetch/SqlServerSourceFetchTaskContext.java x: 257 lines of code y: 2 # changes tools/cdcup/src/download_libs.rb x: 97 lines of code y: 1 # changes tools/cdcup/src/source/my_sql.rb x: 31 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformChangeInfo.java x: 130 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformProcessor.java x: 35 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSink.java x: 49 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksEnrichedCatalog.java x: 75 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/MaxComputeDataSinkOptions.java x: 75 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/options/CompressAlgorithm.java x: 19 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/canal/CanalJsonSerializationSchema.java x: 190 lines of code y: 6 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/serialization/JsonSerializationSchema.java x: 109 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonDataSinkFactory.java x: 104 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketAssignOperator.java x: 191 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperEventSerializer.java x: 101 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/bucket/BucketWrapperFlushEvent.java x: 57 lines of code y: 4 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/TestCaseUtils.java x: 58 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/RecordUtils.java x: 465 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlHybridSplitAssigner.java x: 190 lines of code y: 2 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/FlushEvent.java x: 53 lines of code y: 3 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/EventSerializer.java x: 121 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonCommitter.java x: 59 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/StoreSinkWriteImpl.java x: 178 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/MaxComputeMetadataApplier.java x: 95 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/Constant.java x: 9 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java x: 84 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageCoordinator.java x: 232 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageOperator.java x: 238 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/message/CommitSessionResponse.java x: 12 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/options/MaxComputeOptions.java x: 102 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/sink/MaxComputeEventWriter.java x: 145 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/MaxComputeUtils.java x: 225 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/RetryUtils.java x: 80 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/SchemaEvolutionUtils.java x: 209 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java x: 447 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/writer/BatchUpsertWriter.java x: 132 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java x: 433 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryMapData.java x: 73 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java x: 779 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/InternalSerializers.java x: 67 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java x: 226 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java x: 257 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/binary/BinaryRecordDataDataUtil.java x: 34 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriter.java x: 194 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryWriter.java x: 111 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/DataFieldSerializer.java x: 79 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/DataTypeSerializer.java x: 267 lines of code y: 3 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/RowTypeSerializer.java x: 76 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java x: 155 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseMySQLCatalog.java x: 417 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java x: 179 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseDataSinkOptions.java x: 78 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseEventSerializationSchema.java x: 126 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseMetadataApplier.java x: 152 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseRowConvert.java x: 149 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseUtils.java x: 250 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/AddColumnEvent.java x: 126 lines of code y: 4 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DropTableEvent.java x: 43 lines of code y: 2 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/RenameColumnEvent.java x: 49 lines of code y: 4 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/TableId.java x: 82 lines of code y: 2 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/route/RouteRule.java x: 16 lines of code y: 2 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/DataSource.java x: 15 lines of code y: 3 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/event/SinkWriterRegisterEvent.java x: 29 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/partitioning/PartitioningEvent.java x: 59 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/PartitioningEventSerializer.java x: 71 lines of code y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/event/SchemaChangeEventSerializer.java x: 150 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventDataDeserializer.java x: 106 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/ChunkSplitterState.java x: 108 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/SnapshotPendingSplitsState.java x: 140 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/dialect/Db2ChunkSplitter.java x: 42 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/dialect/MongoDBDialect.java x: 167 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresChunkSplitter.java x: 53 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/PendingSplitsStateSerializer.java x: 357 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/enumerator/MySqlSourceEnumerator.java x: 273 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceEnumeratorMetrics.java x: 189 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/metrics/SourceReaderMetrics.java x: 177 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceRecordEmitter.java x: 146 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/SourceRecordUtils.java x: 151 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java x: 139 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/ShardedSplitStrategy.java x: 93 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SingleSplitStrategy.java x: 34 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SplitStrategy.java x: 21 lines of code y: 2 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/udf/UserDefinedFunctionContext.java x: 5 lines of code y: 1 # changes flink-cdc-pipeline-model/src/main/java/org/apache/flink/cdc/runtime/model/OpenAIEmbeddingModel.java x: 71 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlDeserializationConverterFactory.java x: 132 lines of code y: 2 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/utils/DataTypeUtils.java x: 168 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java x: 729 lines of code y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/CustomPostgresSchema.java x: 105 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomColumnDefinitionParserListener.java x: 267 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java x: 275 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/ValuesDatabase.java x: 422 lines of code y: 5 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/visitor/SchemaChangeEventVisitor.java x: 63 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/BuiltInScalarFunction.java x: 136 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Elasticsearch8AsyncSinkSerializer.java x: 18 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Elasticsearch8AsyncWriter.java x: 157 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/Operation.java x: 22 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/v2/OperationSerializer.java x: 44 lines of code y: 2 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DataSink.java x: 16 lines of code y: 4 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/utils/FactoryDiscoveryUtils.java x: 83 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/sink/ValuesDataSinkOptions.java x: 28 lines of code y: 3 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/PhysicalColumn.java x: 27 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.java x: 294 lines of code y: 3 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/schema/ColumnSerializer.java x: 103 lines of code y: 2 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigurationUtils.java x: 240 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/utils/SqlServerUtils.java x: 369 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/offset/BinlogOffsetUtils.java x: 25 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/utils/Db2Utils.java x: 334 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/utils/OracleSchema.java x: 51 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/TiDBTableSource.java x: 171 lines of code y: 2 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java x: 214 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonDataSinkOptions.java x: 36 lines of code y: 2 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/Predicates.java x: 143 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/MySqlValidator.java x: 190 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlConnection.java x: 571 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/TiKVRichParallelSourceFunction.java x: 339 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2Connection.java x: 413 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/OceanBaseRichSourceFunction.java x: 517 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/connection/OceanBaseConnection.java x: 268 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/converter/OceanBaseValueConverters.java x: 457 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/schema/OceanBaseSchema.java x: 51 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSource.java x: 286 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/table/OceanBaseTableSourceFactory.java x: 284 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/relational/handler/SchemaChangeEventHandler.java x: 8 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2StreamingChangeEventSource.java x: 398 lines of code y: 1 # changes flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/YamlParserUtils.java x: 195 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java x: 333 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java x: 1193 lines of code y: 3 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/FallbackKey.java x: 40 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/StructuredOptionsSplitter.java x: 131 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/BlockElement.java x: 4 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ArrayData.java x: 118 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/DecimalData.java x: 113 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java x: 230 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/ZonedTimestampData.java x: 110 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java x: 615 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java x: 357 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypeChecks.java x: 158 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java x: 164 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DecimalType.java x: 83 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/RowType.java x: 174 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/InstantiationUtil.java x: 185 lines of code y: 1 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/TimeUtils.java x: 139 lines of code y: 1 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/SourceDef.java x: 54 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/utils/VersionComparable.java x: 76 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/DebeziumSourceFunction.java x: 400 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/history/FlinkJsonTableChangeSerializer.java x: 166 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/internal/FlinkOffsetBackingStore.java x: 147 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/MongoDBSource.java x: 264 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/internal/MongoDBConnectorSourceTask.java x: 280 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBScanFetchTask.java x: 171 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/CollectionDiscoveryUtils.java x: 198 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBConnectorDeserializationSchema.java x: 678 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/dispatcher/SignalEventDispatcher.java x: 88 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplitSerializer.java x: 216 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleDeserializationConverterFactory.java x: 212 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/Utils.java x: 51 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/table/RowDataTiKVEventDeserializationSchemaBase.java x: 459 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-vitess-cdc/src/main/java/org/apache/flink/cdc/connectors/vitess/VitessSource.java x: 161 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/DummyDocs.java x: 2 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/EnumSerializer.java x: 201 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/LinkedListSerializer.java x: 190 lines of code y: 1 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/ListSerializer.java x: 120 lines of code y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventMetadataDeserializer.java x: 178 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/LogMinerAdapter.java x: 363 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/CDCClient.java x: 200 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/RegionCDCClient.java x: 193 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/common/util/ChannelFactory.java x: 153 lines of code y: 2 # changes flink-cdc-dist/src/main/flink-cdc-bin/conf/flink-cdc.yaml x: 2 lines of code y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational/RelationalChangeRecordEmitter.java x: 223 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java x: 714 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/processor/AbstractLogMinerEventProcessor.java x: 820 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java x: 392 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java x: 620 lines of code y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java x: 749 lines of code y: 2 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/io/debezium/connector/sqlserver/SqlServerStreamingChangeEventSource.java x: 504 lines of code y: 2 # changes
18.0
# changes
  min: 1.0
  average: 2.13
  25th percentile: 1.0
  median: 1.0
  75th percentile: 2.0
  max: 18.0
0 1193.0
lines of code
min: 2.0 | average: 111.8 | 25th percentile: 28.25 | median: 68.0 | 75th percentile: 139.0 | max: 1193.0

Number of Contributors vs. Number of Changes: 924 points

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/YarnApplicationDeploymentExecutor.java x: 2 # contributors y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaCoordinator.java x: 2 # contributors y: 4 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaOperator.java x: 4 # contributors y: 6 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java x: 6 # contributors y: 7 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java x: 3 # contributors y: 3 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresScanFetchTask.java x: 3 # contributors y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/JdbcSourceConfigFactory.java x: 5 # contributors y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnectionUtils.java x: 1 # contributors y: 1 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDialect.java x: 5 # contributors y: 6 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableFactory.java x: 6 # contributors y: 6 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/SystemFunctionUtils.java x: 5 # contributors y: 11 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/JaninoCompiler.java x: 5 # contributors y: 12 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceConfig.java x: 8 # contributors y: 8 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaRegistry.java x: 4 # contributors y: 3 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DataChangeEvent.java x: 3 # contributors y: 5 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaMergingUtils.java x: 2 # contributors y: 3 # changes flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaUtils.java x: 4 # contributors y: 12 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposer.java x: 11 # contributors y: 18 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/TransformTranslator.java x: 7 # contributors y: 12 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformChangeInfo.java x: 1 # contributors y: 2 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperator.java x: 5 # contributors y: 15 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperator.java x: 4 # contributors y: 15 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/ProjectionColumnProcessor.java x: 5 # contributors y: 10 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformFilterProcessor.java x: 5 # contributors y: 8 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformProjectionProcessor.java x: 4 # contributors y: 7 # changes flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/TransformParser.java x: 8 # contributors y: 17 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitSerializer.java x: 4 # contributors y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java x: 8 # contributors y: 10 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java x: 5 # contributors y: 9 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSourceTranslator.java x: 5 # contributors y: 7 # changes flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/SchemaOperatorTranslator.java x: 6 # contributors y: 9 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlPipelineRecordEmitter.java x: 7 # contributors y: 7 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/factory/ValuesDataFactory.java x: 4 # contributors y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSource.java x: 8 # contributors y: 9 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSinkOptions.java x: 2 # contributors y: 5 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java x: 4 # contributors y: 8 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonSerializationSchema.java x: 3 # contributors y: 6 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriter.java x: 2 # contributors y: 8 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonEventSink.java x: 1 # contributors y: 3 # changes flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java x: 7 # contributors y: 11 # changes tools/maven/suppressions.xml x: 6 # contributors y: 10 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java x: 10 # contributors y: 13 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonRecordEventSerializer.java x: 1 # contributors y: 4 # changes flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReader.java x: 7 # contributors y: 8 # changes flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomAlterTableParserListener.java x: 6 # contributors y: 8 # changes
18.0
# changes
  min: 1.0
  average: 2.13
  25th percentile: 1.0
  median: 1.0
  75th percentile: 2.0
  max: 18.0
0 11.0
# contributors
min: 1.0 | average: 1.82 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 11.0

Number of Contributors vs. File Size: 924 points

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/YarnApplicationDeploymentExecutor.java x: 2 # contributors y: 122 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaCoordinator.java x: 2 # contributors y: 367 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/SchemaOperator.java x: 4 # contributors y: 185 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/Schema.java x: 6 # contributors y: 291 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceSplitReader.java x: 2 # contributors y: 234 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/SnapshotSplitReader.java x: 3 # contributors y: 381 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSplitReader.java x: 3 # contributors y: 205 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlRecords.java x: 2 # contributors y: 53 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresScanFetchTask.java x: 3 # contributors y: 309 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/JdbcSourceConfigFactory.java x: 5 # contributors y: 147 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/dialect/DataSourceDialect.java x: 3 # contributors y: 35 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupMode.java x: 2 # contributors y: 10 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/StartupOptions.java x: 2 # contributors y: 89 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/StreamSplitAssigner.java x: 5 # contributors y: 156 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnectionUtils.java x: 1 # contributors y: 47 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresDialect.java x: 5 # contributors y: 200 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableFactory.java x: 6 # contributors y: 237 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/functions/SystemFunctionUtils.java x: 5 # contributors y: 902 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/JaninoCompiler.java x: 5 # contributors y: 544 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceReader.java x: 3 # contributors y: 431 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational/RelationalTableFilters.java x: 1 # contributors y: 104 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/DebeziumOptions.java x: 2 # contributors y: 30 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceConfig.java x: 8 # contributors y: 226 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaRegistry.java x: 4 # contributors y: 285 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/DataChangeEvent.java x: 3 # contributors y: 183 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaMergingUtils.java x: 2 # contributors y: 818 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/SchemaUtils.java x: 4 # contributors y: 488 lines of code flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/FlinkPipelineComposer.java x: 11 # contributors y: 194 lines of code flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/TransformTranslator.java x: 7 # contributors y: 111 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformChangeInfo.java x: 1 # contributors y: 95 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperator.java x: 5 # contributors y: 398 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformOperatorBuilder.java x: 1 # contributors y: 66 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PostTransformer.java x: 2 # contributors y: 40 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperator.java x: 4 # contributors y: 390 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/PreTransformOperatorBuilder.java x: 1 # contributors y: 61 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/ProjectionColumnProcessor.java x: 5 # contributors y: 133 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformContext.java x: 1 # contributors y: 45 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformFilter.java x: 3 # contributors y: 72 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformFilterProcessor.java x: 5 # contributors y: 168 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformProjection.java x: 3 # contributors y: 40 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformProjectionProcessor.java x: 4 # contributors y: 73 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformRule.java x: 3 # contributors y: 61 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/UserDefinedFunctionDescriptor.java x: 2 # contributors y: 134 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/TransformParser.java x: 8 # contributors y: 512 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SourceSplitSerializer.java x: 4 # contributors y: 234 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceOptions.java x: 2 # contributors y: 141 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSource.java x: 5 # contributors y: 353 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBTableSourceFactory.java x: 5 # contributors y: 208 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/splitter/JdbcSourceChunkSplitter.java x: 8 # contributors y: 398 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/assigner/splitter/OracleChunkSplitter.java x: 6 # contributors y: 132 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/dialect/SqlServerChunkSplitter.java x: 5 # contributors y: 50 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/factory/DorisDataSinkFactory.java x: 3 # contributors y: 136 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisDataSinkOptions.java x: 2 # contributors y: 153 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisEventSerializer.java x: 3 # contributors y: 129 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisMetadataApplier.java x: 5 # contributors y: 273 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/utils/DorisSchemaUtils.java x: 1 # contributors y: 90 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/PipelineOptions.java x: 4 # contributors y: 76 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/pipeline/RuntimeExecutionMode.java x: 1 # contributors y: 7 lines of code flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/definition/PipelineDef.java x: 4 # contributors y: 143 lines of code flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSinkTranslator.java x: 5 # contributors y: 179 lines of code flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/DataSourceTranslator.java x: 5 # contributors y: 69 lines of code flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/PartitioningTranslator.java x: 6 # contributors y: 73 lines of code flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/translator/SchemaOperatorTranslator.java x: 6 # contributors y: 159 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/factory/MySqlDataSourceFactory.java x: 11 # contributors y: 461 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlPipelineRecordEmitter.java x: 7 # contributors y: 231 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/factory/ValuesDataFactory.java x: 4 # contributors y: 90 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/ValuesDataSourceHelper.java x: 6 # contributors y: 937 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlSource.java x: 3 # contributors y: 209 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaDerivator.java x: 3 # contributors y: 321 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/common/SchemaManager.java x: 2 # contributors y: 290 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/regular/BatchSchemaOperator.java x: 1 # contributors y: 134 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/BatchDataSinkFunctionOperator.java x: 1 # contributors y: 24 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/BatchDataSinkWriterOperator.java x: 1 # contributors y: 141 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkWriterOperatorFactory.java x: 2 # contributors y: 57 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed/SchemaCoordinator.java x: 1 # contributors y: 362 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed/SchemaOperator.java x: 3 # contributors y: 176 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/IcebergMetadataApplier.java x: 1 # contributors y: 244 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/IcebergTypeUtils.java x: 1 # contributors y: 169 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/OptionUtils.java x: 1 # contributors y: 16 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/utils/RowDataUtils.java x: 1 # contributors y: 38 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergCommitter.java x: 1 # contributors y: 115 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/IcebergSink.java x: 1 # contributors y: 121 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/TableMetric.java x: 1 # contributors y: 13 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/TableSchemaWrapper.java x: 1 # contributors y: 20 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-iceberg/src/main/java/org/apache/flink/cdc/connectors/iceberg/sink/v2/WriteResultWrapperSerializer.java x: 1 # contributors y: 37 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/utils/JdbcChunkUtils.java x: 2 # contributors y: 80 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/util/ChunkUtils.java x: 2 # contributors y: 48 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/ChunkUtils.java x: 2 # contributors y: 46 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/table/RowDataDebeziumDeserializeSchema.java x: 3 # contributors y: 529 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceOptions.java x: 8 # contributors y: 239 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSource.java x: 8 # contributors y: 385 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/table/MySqlTableSourceFactory.java x: 7 # contributors y: 334 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/ChangeLogJsonFormatFactory.java x: 3 # contributors y: 66 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSinkFactory.java x: 5 # contributors y: 109 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/sink/KafkaDataSinkOptions.java x: 2 # contributors y: 76 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/event/DebeziumEventDeserializationSchema.java x: 2 # contributors y: 353 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/SnapshotSplitAssigner.java x: 4 # contributors y: 585 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlChunkSplitter.java x: 5 # contributors y: 378 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/MySqlSnapshotSplitAssigner.java x: 4 # contributors y: 517 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-doris/src/main/java/org/apache/flink/cdc/connectors/doris/sink/DorisSchemaChangeManager.java x: 3 # contributors y: 23 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonSerializationSchema.java x: 3 # contributors y: 343 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/debezium/DebeziumJsonStruct.java x: 1 # contributors y: 53 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/utils/JsonRowDataSerializationSchemaUtils.java x: 1 # contributors y: 101 lines of code flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontendOptions.java x: 5 # contributors y: 91 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriter.java x: 2 # contributors y: 171 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/utils/PostgresQueryUtils.java x: 4 # contributors y: 318 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/sink/DataSinkFunctionOperator.java x: 3 # contributors y: 103 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/ProjectionColumn.java x: 3 # contributors y: 112 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionCompiler.java x: 3 # contributors y: 50 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformExpressionKey.java x: 3 # contributors y: 84 lines of code flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliExecutor.java x: 5 # contributors y: 107 lines of code flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontend.java x: 7 # contributors y: 197 lines of code flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/PipelineDefinitionParser.java x: 3 # contributors y: 8 lines of code flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/parser/YamlPipelineDefinitionParser.java x: 7 # contributors y: 286 lines of code flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/FlinkEnvironmentUtils.java x: 5 # contributors y: 29 lines of code flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/K8SApplicationDeploymentExecutor.java x: 2 # contributors y: 66 lines of code tools/maven/suppressions.xml x: 6 # contributors y: 11 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlSourceReader.java x: 4 # contributors y: 456 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlBinlogSplit.java x: 4 # contributors y: 254 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/enumerator/PostgresSourceEnumerator.java x: 2 # contributors y: 100 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/reader/PostgresSourceReader.java x: 3 # contributors y: 96 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSinkFactory.java x: 4 # contributors y: 146 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksDataSinkOptions.java x: 2 # contributors y: 106 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/MySqlDataSourceOptions.java x: 10 # contributors y: 267 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/options/SourceOptions.java x: 4 # contributors y: 116 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/Db2TableSource.java x: 5 # contributors y: 289 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/Db2TableSourceFactory.java x: 5 # contributors y: 227 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSource.java x: 5 # contributors y: 310 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/table/OracleTableSourceFactory.java x: 5 # contributors y: 204 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/table/PostgreSQLTableSource.java x: 5 # contributors y: 346 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableFactory.java x: 4 # contributors y: 229 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/table/SqlServerTableSource.java x: 4 # contributors y: 296 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/source/ValuesDataSource.java x: 3 # contributors y: 267 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonRecordEventSerializer.java x: 1 # contributors y: 62 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/PaimonWriterHelper.java x: 2 # contributors y: 293 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/config/BaseSourceConfig.java x: 3 # contributors y: 86 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/Db2SourceBuilder.java x: 4 # contributors y: 128 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/MongoDBSourceBuilder.java x: 3 # contributors y: 115 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/assigners/splitters/SampleBucketSplitStrategy.java x: 3 # contributors y: 118 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/config/MongoDBSourceConfig.java x: 3 # contributors y: 212 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/config/MySqlSourceConfigFactory.java x: 7 # contributors y: 253 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/OracleSourceBuilder.java x: 4 # contributors y: 140 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/config/OracleSourceConfig.java x: 4 # contributors y: 80 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/config/OracleSourceConfigFactory.java x: 4 # contributors y: 89 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/PostgresSourceBuilder.java x: 6 # contributors y: 265 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/config/PostgresSourceConfigFactory.java x: 4 # contributors y: 103 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/SqlServerSourceBuilder.java x: 3 # contributors y: 126 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/reader/BinlogSplitReader.java x: 7 # contributors y: 303 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplier.java x: 8 # contributors y: 316 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/io/debezium/connector/sqlserver/SqlServerOffsetContext.java x: 1 # contributors y: 192 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/offset/LsnOffset.java x: 2 # contributors y: 63 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/HybridSplitAssigner.java x: 4 # contributors y: 235 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/offset/OffsetDeserializerSerializer.java x: 2 # contributors y: 95 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/StreamSplit.java x: 3 # contributors y: 247 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/AbstractBinaryWriter.java x: 4 # contributors y: 270 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/task/MySqlSnapshotSplitReadTask.java x: 3 # contributors y: 319 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/config/ElasticsearchSinkOptions.java x: 2 # contributors y: 113 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/serializer/ElasticsearchEventSerializer.java x: 2 # contributors y: 208 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkFactory.java x: 2 # contributors y: 159 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-elasticsearch/src/main/java/org/apache/flink/cdc/connectors/elasticsearch/sink/ElasticsearchDataSinkOptions.java x: 2 # contributors y: 74 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomAlterTableParserListener.java x: 6 # contributors y: 380 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/MySqlSource.java x: 2 # contributors y: 150 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/MetadataApplier.java x: 3 # contributors y: 26 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomMySqlAntlrDdlParser.java x: 2 # contributors y: 260 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/parser/CustomMySqlAntlrDdlParserListener.java x: 2 # contributors y: 92 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/utils/MySqlTypeUtils.java x: 4 # contributors y: 211 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/schema/MySqlTypeUtils.java x: 2 # contributors y: 200 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/table/StartupOptions.java x: 4 # contributors y: 37 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/converters/MysqlDebeziumTimeConverter.java x: 3 # contributors y: 282 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/parser/metadata/TransformSqlOperatorTable.java x: 6 # contributors y: 309 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/typeutils/DataTypeConverter.java x: 4 # contributors y: 791 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/sink/ValuesDataSinkHelper.java x: 3 # contributors y: 56 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch/Db2ScanFetchTask.java x: 2 # contributors y: 282 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/fetch/Db2SourceFetchTaskContext.java x: 3 # contributors y: 251 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/EventProcessorFactory.java x: 2 # contributors y: 244 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/OracleScanFetchTask.java x: 2 # contributors y: 276 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/OracleSourceFetchTaskContext.java x: 2 # contributors y: 264 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/OracleStreamFetchTask.java x: 2 # contributors y: 127 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresSourceFetchTaskContext.java x: 2 # contributors y: 300 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/org/apache/flink/cdc/connectors/postgres/source/fetch/PostgresStreamFetchTask.java x: 2 # contributors y: 188 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/reader/fetch/SqlServerSourceFetchTaskContext.java x: 2 # contributors y: 257 lines of code tools/cdcup/src/source/my_sql.rb x: 1 # contributors y: 31 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksEnrichedCatalog.java x: 1 # contributors y: 75 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplier.java x: 3 # contributors y: 271 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/json/canal/CanalJsonSerializationSchema.java x: 3 # contributors y: 190 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-kafka/src/main/java/org/apache/flink/cdc/connectors/kafka/serialization/JsonSerializationSchema.java x: 2 # contributors y: 109 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/utils/RecordUtils.java x: 3 # contributors y: 465 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/StoreSinkWriteImpl.java x: 1 # contributors y: 178 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/common/SessionIdentifier.java x: 1 # contributors y: 84 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageCoordinator.java x: 1 # contributors y: 232 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/coordinator/SessionManageOperator.java x: 1 # contributors y: 238 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/MaxComputeUtils.java x: 1 # contributors y: 225 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/SchemaEvolutionUtils.java x: 1 # contributors y: 209 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-maxcompute/src/main/java/org/apache/flink/cdc/connectors/maxcompute/utils/TypeConvertUtils.java x: 1 # contributors y: 447 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryArrayData.java x: 1 # contributors y: 433 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryRecordData.java x: 2 # contributors y: 205 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinarySegmentUtils.java x: 2 # contributors y: 779 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/ArrayDataSerializer.java x: 2 # contributors y: 226 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/MapDataSerializer.java x: 1 # contributors y: 257 lines of code flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/serializer/data/writer/BinaryArrayWriter.java x: 1 # contributors y: 194 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseColumn.java x: 1 # contributors y: 155 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseMySQLCatalog.java x: 1 # contributors y: 417 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/catalog/OceanBaseTable.java x: 1 # contributors y: 179 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseDataSinkOptions.java x: 1 # contributors y: 78 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseEventSerializationSchema.java x: 1 # contributors y: 126 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseMetadataApplier.java x: 1 # contributors y: 152 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseRowConvert.java x: 1 # contributors y: 149 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-oceanbase/src/main/java/org/apache/flink/cdc/connectors/oceanbase/sink/OceanBaseUtils.java x: 1 # contributors y: 250 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/SchemaChangeEvent.java x: 2 # contributors y: 8 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/source/DataSource.java x: 2 # contributors y: 15 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventDataDeserializer.java x: 4 # contributors y: 106 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/assigner/state/SnapshotPendingSplitsState.java x: 3 # contributors y: 140 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/dialect/MongoDBDialect.java x: 2 # contributors y: 167 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/OracleDialect.java x: 2 # contributors y: 126 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/assigners/state/PendingSplitsStateSerializer.java x: 2 # contributors y: 357 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/enumerator/IncrementalSourceEnumerator.java x: 3 # contributors y: 281 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/enumerator/MySqlSourceEnumerator.java x: 4 # contributors y: 273 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/reader/IncrementalSourceRecordEmitter.java x: 3 # contributors y: 146 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-cdc-base/src/main/java/org/apache/flink/cdc/connectors/base/source/meta/split/SnapshotSplit.java x: 1 # contributors y: 139 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/utils/DataTypeUtils.java x: 4 # contributors y: 168 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java x: 5 # contributors y: 729 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/debezium/DebeziumUtils.java x: 3 # contributors y: 275 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-values/src/main/java/org/apache/flink/cdc/connectors/values/ValuesDatabase.java x: 4 # contributors y: 422 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/main/java/org/apache/flink/cdc/connectors/paimon/sink/v2/MultiTableCommittableChannelComputer.java x: 2 # contributors y: 33 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/sink/DataSink.java x: 4 # contributors y: 16 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/schema/PhysicalColumn.java x: 2 # contributors y: 27 lines of code flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/main/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksUtils.java x: 3 # contributors y: 294 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/org/apache/flink/cdc/connectors/sqlserver/source/utils/SqlServerUtils.java x: 3 # contributors y: 369 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/org/apache/flink/cdc/connectors/db2/source/utils/Db2Utils.java x: 2 # contributors y: 334 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/Configuration.java x: 2 # contributors y: 214 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlConnection.java x: 3 # contributors y: 571 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/metrics/MySqlSourceReaderMetrics.java x: 2 # contributors y: 23 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/apache/flink/cdc/connectors/tidb/TiKVRichParallelSourceFunction.java x: 2 # contributors y: 339 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2Connection.java x: 1 # contributors y: 413 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/OceanBaseRichSourceFunction.java x: 2 # contributors y: 517 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/connection/OceanBaseConnection.java x: 1 # contributors y: 268 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/main/java/org/apache/flink/cdc/connectors/oceanbase/source/converter/OceanBaseValueConverters.java x: 1 # contributors y: 457 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-db2-cdc/src/main/java/io/debezium/connector/db2/Db2StreamingChangeEventSource.java x: 1 # contributors y: 398 lines of code flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/utils/YamlParserUtils.java x: 2 # contributors y: 195 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBStreamFetchTask.java x: 2 # contributors y: 333 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/MongoUtils.java x: 2 # contributors y: 362 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java x: 3 # contributors y: 1193 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOption.java x: 1 # contributors y: 109 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/ConfigOptions.java x: 1 # contributors y: 86 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/StructuredOptionsSplitter.java x: 1 # contributors y: 131 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/configuration/description/BlockElement.java x: 1 # contributors y: 4 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/GenericArrayData.java x: 1 # contributors y: 230 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/data/binary/BinaryStringData.java x: 1 # contributors y: 615 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/text/TokenStream.java x: 1 # contributors y: 357 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/types/DataTypes.java x: 1 # contributors y: 164 lines of code flink-cdc-common/src/main/java/org/apache/flink/cdc/common/utils/InstantiationUtil.java x: 1 # contributors y: 185 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/org/apache/flink/cdc/debezium/DebeziumSourceFunction.java x: 1 # contributors y: 400 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/MongoDBSource.java x: 1 # contributors y: 264 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/internal/MongoDBConnectorSourceTask.java x: 1 # contributors y: 280 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/reader/fetch/MongoDBScanFetchTask.java x: 1 # contributors y: 171 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/source/utils/CollectionDiscoveryUtils.java x: 1 # contributors y: 198 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mongodb-cdc/src/main/java/org/apache/flink/cdc/connectors/mongodb/table/MongoDBConnectorDeserializationSchema.java x: 1 # contributors y: 678 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/org/apache/flink/cdc/connectors/mysql/source/split/MySqlSplitSerializer.java x: 1 # contributors y: 216 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/com/github/shyiko/mysql/binlog/event/deserialization/TableMapEventMetadataDeserializer.java x: 2 # contributors y: 178 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/LogMinerAdapter.java x: 3 # contributors y: 363 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/CDCClient.java x: 3 # contributors y: 200 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-tidb-cdc/src/main/java/org/tikv/cdc/RegionCDCClient.java x: 3 # contributors y: 193 lines of code flink-cdc-dist/src/main/flink-cdc-bin/conf/flink-cdc.yaml x: 3 # contributors y: 2 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-debezium/src/main/java/io/debezium/relational/RelationalChangeRecordEmitter.java x: 2 # contributors y: 223 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlDefaultValueConverter.java x: 2 # contributors y: 352 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlValueConverters.java x: 2 # contributors y: 714 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/PostgresStreamingChangeEventSource.java x: 2 # contributors y: 392 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java x: 2 # contributors y: 620 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java x: 2 # contributors y: 749 lines of code flink-cdc-connect/flink-cdc-source-connectors/flink-connector-sqlserver-cdc/src/main/java/io/debezium/connector/sqlserver/SqlServerStreamingChangeEventSource.java x: 2 # contributors y: 504 lines of code
1193.0
lines of code
  min: 2.0
  average: 111.8
  25th percentile: 28.25
  median: 68.0
  75th percentile: 139.0
  max: 1193.0
0 11.0
# contributors
min: 1.0 | average: 1.82 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 11.0