apache / doris-flink-connector
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 196 files with 20,434 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 10 files changed 21-50 times (4,124 lines of code)
    • 47 files changed 6-20 times (7,837 lines of code)
    • 139 files changed 1-5 times (8,473 lines of code)
0% | 0% | 20% | 38% | 41%
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 196 files with 20,434 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 2 files changed by 11-25 contributors (1,238 lines of code)
    • 12 files changed by 6-10 contributors (3,703 lines of code)
    • 143 files changed by 2-5 contributors (13,015 lines of code)
    • 39 files changed by 1 contributor (2,478 lines of code)
0% | 6% | 18% | 63% | 12%
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, yaml, txt, sql, sh, md, xml, properties, gitignore, tpl
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 20% | 38% | 41%
xml0% | 0% | 0% | 0% | 100%
tpl0% | 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-doris-connector0% | 0% | 20% | 38% | 41%
tools0% | 0% | 0% | 0% | 100%
ROOT0% | 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
DatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 475 34 2023-06-05 2025-03-27 47 10 676366545@qq.com 76644839+kwonder0926@users....
DorisWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 355 21 2022-03-08 2025-03-18 29 7 44109015+madongz@users.nore... 676366545@qq.com
DorisStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 482 18 2022-03-08 2025-03-18 28 6 44109015+madongz@users.nore... 676366545@qq.com
RestService.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
 639 21 2022-02-11 2025-03-13 26 11 chenmingyu@baidu.com 676366545@qq.com
DorisDynamicTableFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 240 7 2022-02-11 2024-08-12 25 8 chenmingyu@baidu.com xyws5566@qq.com
DorisConfigOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 279 1 2022-09-06 2025-03-18 25 6 676366545@qq.com 676366545@qq.com
RowBatch.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/serialization
 599 19 2022-02-11 2025-03-17 25 12 chenmingyu@baidu.com 1401597760@qq.com
CdcTools.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 196 11 2023-06-05 2024-12-02 23 6 676366545@qq.com 676366545@qq.com
DorisExecutionOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 339 46 2022-02-11 2025-03-18 23 7 chenmingyu@baidu.com 676366545@qq.com
DorisBatchStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 520 25 2023-08-07 2025-03-18 22 7 676366545@qq.com 676366545@qq.com
DorisSystem.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 151 17 2023-06-05 2024-08-30 20 5 676366545@qq.com 46414265+dongliang-0@users....
DorisDynamicTableSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 223 13 2022-02-11 2025-02-12 19 7 chenmingyu@baidu.com 676366545@qq.com
OracleDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 220 7 2023-07-19 2025-01-02 18 4 676366545@qq.com 676366545@qq.com
MysqlDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 227 8 2023-06-05 2024-08-12 17 5 676366545@qq.com 31833513+vinlee19@users.nor...
JsonDebeziumSchemaSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer
 269 18 2023-11-21 2025-02-26 16 3 676366545@qq.com 676366545@qq.com
DorisTypeMapper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 230 24 2022-09-06 2024-07-17 15 6 676366545@qq.com 676366545@qq.com
JsonDebeziumSchemaChangeImplV2.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
 289 16 2024-01-03 2025-03-19 15 3 46414265+dongliang-0@users.... 676366545@qq.com
DorisDynamicTableSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 159 9 2022-02-11 2025-01-20 14 7 chenmingyu@baidu.com 676366545@qq.com
DorisCommitter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer
 143 5 2022-03-08 2025-01-07 13 5 44109015+madongz@users.nore... 676366545@qq.com
DorisSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 148 14 2022-03-08 2024-10-11 13 3 44109015+madongz@users.nore... 676366545@qq.com
SourceSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 95 14 2023-06-05 2024-12-06 12 4 676366545@qq.com 676366545@qq.com
DorisReadOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 274 40 2022-02-11 2025-03-13 12 4 chenmingyu@baidu.com 676366545@qq.com
DorisRowConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter
 355 20 2022-04-21 2024-03-13 12 5 676366545@qq.com 31833513+vinlee19@users.nor...
DorisCatalog.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 478 46 2022-09-06 2024-07-30 12 4 676366545@qq.com 46414265+dongliang-0@users....
LabelGenerator.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 63 9 2022-06-30 2025-01-10 11 3 44109015+madongz@users.nore... 676366545@qq.com
BackendUtil.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 101 8 2023-08-07 2024-09-14 11 4 676366545@qq.com 676366545@qq.com
DorisOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 104 16 2022-02-11 2024-10-11 11 3 chenmingyu@baidu.com 676366545@qq.com
SqlServerDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver
 193 7 2023-08-24 2024-08-12 11 4 676366545@qq.com 31833513+vinlee19@users.nor...
PostgresDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres
 213 7 2023-08-15 2024-12-04 11 4 676366545@qq.com 676366545@qq.com
HttpUtil.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 75 6 2022-03-08 2025-02-21 10 4 44109015+madongz@users.nore... 676366545@qq.com
DorisBatchWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 142 10 2023-08-07 2025-02-19 10 4 676366545@qq.com 676366545@qq.com
SchemaChangeHelper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema
 177 17 2023-11-23 2024-11-25 10 3 676366545@qq.com 37775475+qg-lin@users.norep...
MongoDBDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
 205 11 2024-05-08 2025-03-27 10 7 bingquan_zhao@icloud.com 76644839+kwonder0926@users....
DorisSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source
 147 14 2022-04-21 2024-12-26 9 4 676366545@qq.com 676366545@qq.com
MysqlType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 184 1 2023-06-05 2024-08-23 9 5 676366545@qq.com tmc9031@users.noreply.githu...
SchemaChangeManager.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema
 311 23 2023-11-23 2024-09-20 9 3 46414265+dongliang-0@users.... 37775475+qg-lin@users.norep...
LoadConstants.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 26 - 2022-03-08 2025-03-18 8 5 44109015+madongz@users.nore... 676366545@qq.com
ConfigurationOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 35 - 2022-02-11 2025-03-13 8 4 chenmingyu@baidu.com 676366545@qq.com
JsonDebeziumSchemaChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
 156 14 2024-01-03 2025-03-19 8 3 46414265+dongliang-0@users.... 676366545@qq.com
DorisValueReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
 246 9 2022-07-21 2025-02-12 8 3 676366545@qq.com 676366545@qq.com
DorisConnectionOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 88 16 2022-02-11 2024-06-05 7 3 chenmingyu@baidu.com 676366545@qq.com
SqlServerType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver
 93 1 2023-08-24 2024-04-09 7 4 676366545@qq.com 31833513+vinlee19@users.nor...
SQLParserSchemaChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
 98 5 2024-07-17 2025-03-19 7 2 46414265+dongliang-0@users.... 676366545@qq.com
DorisCatalogFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 99 2 2022-09-06 2024-05-30 7 4 676366545@qq.com 676366545@qq.com
DorisRowDataInputFormat.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 146 22 2022-02-11 2023-12-15 7 5 chenmingyu@baidu.com 46414265+dongliang-0@users....
Worker.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 208 8 2023-01-17 2025-03-12 7 3 676366545@qq.com 676366545@qq.com
DorisSourceSplitReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
 80 7 2022-04-21 2024-09-10 6 3 676366545@qq.com 676366545@qq.com
DorisBatchSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 80 4 2023-08-07 2024-06-05 6 2 676366545@qq.com 676366545@qq.com
DorisSourceFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/datastream
 85 6 2022-02-11 2024-06-05 6 4 chenmingyu@baidu.com 676366545@qq.com
HttpPutBuilder.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 93 16 2022-03-08 2024-08-15 6 3 44109015+madongz@users.nore... 676366545@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
RowBatch.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/serialization
 599 19 2022-02-11 2025-03-17 25 12 chenmingyu@baidu.com 1401597760@qq.com
RestService.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
 639 21 2022-02-11 2025-03-13 26 11 chenmingyu@baidu.com 676366545@qq.com
DatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 475 34 2023-06-05 2025-03-27 47 10 676366545@qq.com 76644839+kwonder0926@users....
DorisDynamicTableFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 240 7 2022-02-11 2024-08-12 25 8 chenmingyu@baidu.com xyws5566@qq.com
DorisWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 355 21 2022-03-08 2025-03-18 29 7 44109015+madongz@users.nore... 676366545@qq.com
DorisExecutionOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 339 46 2022-02-11 2025-03-18 23 7 chenmingyu@baidu.com 676366545@qq.com
DorisBatchStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 520 25 2023-08-07 2025-03-18 22 7 676366545@qq.com 676366545@qq.com
DorisDynamicTableSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 223 13 2022-02-11 2025-02-12 19 7 chenmingyu@baidu.com 676366545@qq.com
DorisDynamicTableSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 159 9 2022-02-11 2025-01-20 14 7 chenmingyu@baidu.com 676366545@qq.com
MongoDBDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
 205 11 2024-05-08 2025-03-27 10 7 bingquan_zhao@icloud.com 76644839+kwonder0926@users....
DorisStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 482 18 2022-03-08 2025-03-18 28 6 44109015+madongz@users.nore... 676366545@qq.com
DorisConfigOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 279 1 2022-09-06 2025-03-18 25 6 676366545@qq.com 676366545@qq.com
CdcTools.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 196 11 2023-06-05 2024-12-02 23 6 676366545@qq.com 676366545@qq.com
DorisTypeMapper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 230 24 2022-09-06 2024-07-17 15 6 676366545@qq.com 676366545@qq.com
DorisSystem.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 151 17 2023-06-05 2024-08-30 20 5 676366545@qq.com 46414265+dongliang-0@users....
MysqlDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 227 8 2023-06-05 2024-08-12 17 5 676366545@qq.com 31833513+vinlee19@users.nor...
DorisCommitter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer
 143 5 2022-03-08 2025-01-07 13 5 44109015+madongz@users.nore... 676366545@qq.com
DorisRowConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter
 355 20 2022-04-21 2024-03-13 12 5 676366545@qq.com 31833513+vinlee19@users.nor...
MysqlType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 184 1 2023-06-05 2024-08-23 9 5 676366545@qq.com tmc9031@users.noreply.githu...
LoadConstants.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 26 - 2022-03-08 2025-03-18 8 5 44109015+madongz@users.nore... 676366545@qq.com
DorisRowDataInputFormat.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 146 22 2022-02-11 2023-12-15 7 5 chenmingyu@baidu.com 46414265+dongliang-0@users....
PostgresType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres
 118 1 2023-08-15 2025-04-01 6 5 676366545@qq.com 48339061+aalron@users.norep...
RespContent.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
 112 20 2022-02-11 2024-06-05 6 5 chenmingyu@baidu.com 676366545@qq.com
OracleDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 220 7 2023-07-19 2025-01-02 18 4 676366545@qq.com 676366545@qq.com
DorisReadOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 274 40 2022-02-11 2025-03-13 12 4 chenmingyu@baidu.com 676366545@qq.com
SourceSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 95 14 2023-06-05 2024-12-06 12 4 676366545@qq.com 676366545@qq.com
DorisCatalog.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 478 46 2022-09-06 2024-07-30 12 4 676366545@qq.com 46414265+dongliang-0@users....
SqlServerDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver
 193 7 2023-08-24 2024-08-12 11 4 676366545@qq.com 31833513+vinlee19@users.nor...
PostgresDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres
 213 7 2023-08-15 2024-12-04 11 4 676366545@qq.com 676366545@qq.com
BackendUtil.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 101 8 2023-08-07 2024-09-14 11 4 676366545@qq.com 676366545@qq.com
DorisBatchWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 142 10 2023-08-07 2025-02-19 10 4 676366545@qq.com 676366545@qq.com
HttpUtil.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 75 6 2022-03-08 2025-02-21 10 4 44109015+madongz@users.nore... 676366545@qq.com
DorisSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source
 147 14 2022-04-21 2024-12-26 9 4 676366545@qq.com 676366545@qq.com
ConfigurationOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 35 - 2022-02-11 2025-03-13 8 4 chenmingyu@baidu.com 676366545@qq.com
SqlServerType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver
 93 1 2023-08-24 2024-04-09 7 4 676366545@qq.com 31833513+vinlee19@users.nor...
DorisCatalogFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 99 2 2022-09-06 2024-05-30 7 4 676366545@qq.com 676366545@qq.com
DorisSourceFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/datastream
 85 6 2022-02-11 2024-06-05 6 4 chenmingyu@baidu.com 676366545@qq.com
BackendClient.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/backend
 222 6 2022-02-11 2024-10-25 6 4 chenmingyu@baidu.com 676366545@qq.com
MongoDBJsonDebeziumSchemaSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer
 186 5 2024-05-30 2025-03-27 5 4 676366545@qq.com 76644839+kwonder0926@users....
OracleSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 31 4 2023-07-19 2024-04-08 5 4 676366545@qq.com 31833513+vinlee19@users.nor...
DorisDeserializationSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization
 10 - 2022-02-11 2024-06-05 5 4 chenmingyu@baidu.com 676366545@qq.com
DorisStreamOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 106 4 2022-02-11 2024-08-12 4 4 chenmingyu@baidu.com xyws5566@qq.com
MongoJsonDebeziumDataChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer
 116 6 2024-05-30 2025-03-27 4 4 676366545@qq.com 76644839+kwonder0926@users....
OracleType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 89 1 2023-07-19 2024-04-02 4 4 676366545@qq.com 71004656+caoliang-web@users...
RecordStream.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 42 6 2022-03-08 2025-03-18 4 4 44109015+madongz@users.nore... 676366545@qq.com
RecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 103 8 2022-03-08 2025-03-18 4 4 44109015+madongz@users.nore... 676366545@qq.com
JsonDebeziumSchemaSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer
 269 18 2023-11-21 2025-02-26 16 3 676366545@qq.com 676366545@qq.com
JsonDebeziumSchemaChangeImplV2.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
 289 16 2024-01-03 2025-03-19 15 3 46414265+dongliang-0@users.... 676366545@qq.com
DorisSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 148 14 2022-03-08 2024-10-11 13 3 44109015+madongz@users.nore... 676366545@qq.com
DorisOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 104 16 2022-02-11 2024-10-11 11 3 chenmingyu@baidu.com 676366545@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
BatchStageLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 367 19 2024-02-01 2024-08-15 5 1 676366545@qq.com 676366545@qq.com
DorisWriteMetrics.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 275 34 2024-01-05 2024-01-05 1 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...
Db2DatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2
 208 7 2024-07-26 2024-08-12 2 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...
DorisJsonDebeziumDeserializationSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/deserialize
 165 4 2024-05-30 2024-07-24 2 1 676366545@qq.com 676366545@qq.com
DorisCopyCommitter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 136 6 2024-02-01 2024-03-19 2 1 676366545@qq.com 676366545@qq.com
IPUtils.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/util
 126 10 2024-04-15 2024-04-15 1 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...
JsonDebeziumSchemaChangeImpl.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
 115 7 2024-01-03 2024-07-17 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
BatchRecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 113 19 2024-08-15 2024-08-15 1 1 676366545@qq.com 676366545@qq.com
Db2DateConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2
 104 7 2024-07-26 2024-07-26 1 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...
ArrowSerializer.java
in flink-doris-connector/src/main/java/org/apache/flink/table/runtime/arrow/serializers
 84 12 2023-12-27 2023-12-27 1 1 wuwenchihdu@hotmail.com wuwenchihdu@hotmail.com
Db2Type.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2
 71 1 2024-07-26 2024-07-26 1 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...
DorisTableUtil.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils
 63 3 2025-03-27 2025-03-27 1 1 76644839+kwonder0926@users.... 76644839+kwonder0926@users....
FastDateUtil.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/util
 63 4 2024-08-12 2024-08-12 1 1 xyws5566@qq.com xyws5566@qq.com
BatchBufferHttpEntity.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 48 7 2024-08-15 2024-08-15 1 1 676366545@qq.com 676366545@qq.com
BatchBufferStream.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 47 4 2024-08-15 2024-08-15 1 1 676366545@qq.com 676366545@qq.com
DorisCopyCommittable.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 43 6 2024-02-01 2024-02-01 1 1 676366545@qq.com 676366545@qq.com
BackoffAndRetryUtils.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 43 1 2024-02-01 2024-02-01 1 1 676366545@qq.com 676366545@qq.com
HttpPostBuilder.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 43 6 2024-02-01 2024-02-01 1 1 676366545@qq.com 676366545@qq.com
CopyCommittableSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 40 2 2024-02-01 2024-02-01 1 1 676366545@qq.com 676366545@qq.com
TableNameConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter
 37 4 2025-02-26 2025-02-26 1 1 676366545@qq.com 676366545@qq.com
Db2Schema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2
 31 4 2024-07-26 2024-08-06 2 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...
JsonNodeExtractUtil.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils
 30 2 2025-03-27 2025-03-27 1 1 76644839+kwonder0926@users.... 76644839+kwonder0926@users....
LookupMetrics.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 26 4 2024-05-08 2024-05-08 1 1 676366545@qq.com 676366545@qq.com
CopyLoadException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
 22 5 2024-02-01 2024-02-01 1 1 676366545@qq.com 676366545@qq.com
LabelAlreadyExistsException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
 22 5 2024-04-15 2025-03-18 2 1 676366545@qq.com 676366545@qq.com
Get.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 19 3 2023-01-17 2023-01-17 1 1 676366545@qq.com 676366545@qq.com
GetAction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 19 4 2023-01-17 2023-01-17 1 1 676366545@qq.com 676366545@qq.com
CopyIntoResp.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/models
 18 3 2024-02-01 2024-02-01 1 1 676366545@qq.com 676366545@qq.com
BaseResponse.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/models
 18 3 2024-02-01 2024-02-01 1 1 676366545@qq.com 676366545@qq.com
WriteMode.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 13 1 2024-01-29 2024-01-29 1 1 676366545@qq.com 676366545@qq.com
DeleteOperation.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/util
 12 1 2023-11-23 2023-11-23 1 1 676366545@qq.com 676366545@qq.com
SchemaChangeMode.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema
 12 1 2024-07-17 2024-07-17 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
CdcDataChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
 12 - 2024-02-29 2024-05-08 2 1 bingquan_zhao@icloud.com bingquan_zhao@icloud.com
DorisLookupReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 10 - 2023-01-17 2023-07-17 2 1 676366545@qq.com 676366545@qq.com
suppressions.xml
in tools/maven
 7 - 2023-12-14 2023-12-15 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DorisAbstractWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 6 - 2024-01-29 2024-01-29 1 1 676366545@qq.com 676366545@qq.com
EventType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 5 - 2023-11-30 2023-11-30 1 1 676366545@qq.com 676366545@qq.com
ChangeEvent.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 3 - 2024-01-03 2024-01-03 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DorisAbstractCommittable.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 2 - 2024-02-01 2024-02-01 1 1 676366545@qq.com 676366545@qq.com
SQLParserSchemaManager.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema
 343 18 2024-07-17 2025-01-10 6 2 46414265+dongliang-0@users.... 781240052@qq.com
DorisSchemaFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 207 12 2024-07-25 2025-02-26 5 2 46414265+dongliang-0@users.... 676366545@qq.com
ExecutionPool.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 187 9 2023-01-17 2023-12-15 4 2 676366545@qq.com 46414265+dongliang-0@users....
DorisFlightValueReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
 184 8 2024-08-12 2025-02-12 3 2 xyws5566@qq.com 676366545@qq.com
DorisCopyWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 164 11 2024-02-01 2024-07-02 4 2 676366545@qq.com 676366545@qq.com
DateToStringConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 141 8 2023-09-15 2024-07-25 4 2 676366545@qq.com 46414265+dongliang-0@users....
DorisRowDataAsyncLookupFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 129 4 2023-01-17 2024-05-08 5 2 676366545@qq.com 676366545@qq.com
DorisLookupOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 127 19 2022-09-15 2024-05-30 4 2 676366545@qq.com 676366545@qq.com
DorisExpressionVisitor.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 126 8 2024-03-22 2024-12-17 3 2 676366545@qq.com 31833513+vinlee19@users.nor...
OracleDateConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 118 5 2023-07-19 2024-07-25 4 2 676366545@qq.com 46414265+dongliang-0@users....
RecordKey.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 109 6 2023-01-17 2023-12-15 2 2 676366545@qq.com 46414265+dongliang-0@users....
Correlations

File Size vs. Number of Changes: 196 points

flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java x: 105 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java x: 118 lines of code y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 475 lines of code y: 47 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java x: 205 lines of code y: 10 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java x: 130 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java x: 186 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java x: 116 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java x: 209 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java x: 63 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java x: 30 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java x: 156 lines of code y: 8 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java x: 289 lines of code y: 15 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java x: 98 lines of code y: 7 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 339 lines of code y: 23 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java x: 22 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java x: 482 lines of code y: 28 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java x: 355 lines of code y: 29 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java x: 26 lines of code y: 8 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java x: 103 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java x: 42 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 279 lines of code y: 25 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java x: 520 lines of code y: 22 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 599 lines of code y: 25 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java x: 35 lines of code y: 8 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java x: 274 lines of code y: 12 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java x: 639 lines of code y: 26 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/ValueReader.java x: 35 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java x: 7 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java x: 208 lines of code y: 7 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactory.java x: 207 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java x: 269 lines of code y: 16 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java x: 130 lines of code y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java x: 57 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter/TableNameConverter.java x: 37 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java x: 23 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java x: 75 lines of code y: 10 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java x: 142 lines of code y: 10 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisFlightValueReader.java x: 184 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisValueReader.java x: 246 lines of code y: 8 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java x: 223 lines of code y: 19 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/ChangeStreamConstant.java x: 21 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/BackendV2.java x: 52 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java x: 87 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java x: 31 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java x: 68 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java x: 34 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java x: 159 lines of code y: 14 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SQLParserSchemaManager.java x: 343 lines of code y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java x: 63 lines of code y: 11 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/CdcSchemaChange.java x: 9 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java x: 143 lines of code y: 13 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java x: 220 lines of code y: 18 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java x: 132 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSource.java x: 147 lines of code y: 9 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisExpressionVisitor.java x: 126 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DorisTableConfig.java x: 78 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/JdbcSourceSchema.java x: 93 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java x: 95 lines of code y: 12 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java x: 213 lines of code y: 11 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/TableSchema.java x: 105 lines of code y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java x: 196 lines of code y: 23 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeHelper.java x: 177 lines of code y: 10 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java x: 222 lines of code y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners/SimpleSplitAssigner.java x: 35 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java x: 26 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java x: 104 lines of code y: 11 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisSink.java x: 148 lines of code y: 13 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/IllegalArgumentException.java x: 12 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeManager.java x: 311 lines of code y: 9 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java x: 101 lines of code y: 11 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSyncConfig.java x: 66 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumerator.java x: 58 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceReader.java x: 50 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceSplitReader.java x: 80 lines of code y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java x: 151 lines of code y: 20 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java x: 51 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java x: 184 lines of code y: 9 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpPutBuilder.java x: 93 lines of code y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchBufferHttpEntity.java x: 48 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchBufferStream.java x: 47 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java x: 98 lines of code y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchRecordBuffer.java x: 113 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java x: 367 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/SchemaUtils.java x: 45 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSplitRecords.java x: 48 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java x: 240 lines of code y: 25 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java x: 208 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java x: 227 lines of code y: 17 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java x: 193 lines of code y: 11 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Schema.java x: 31 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/CopySQLBuilder.java x: 68 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumDataChange.java x: 95 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java x: 478 lines of code y: 12 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeUtils.java x: 71 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceConnector.java x: 16 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DateConverter.java x: 104 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Type.java x: 71 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDateConverter.java x: 17 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java x: 141 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java x: 118 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDateConverter.java x: 104 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDateConverter.java x: 85 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/deserialize/DorisJsonDebeziumDeserializationSchema.java x: 165 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/FieldSchema.java x: 60 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java x: 230 lines of code y: 15 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisType.java x: 31 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeMode.java x: 12 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImpl.java x: 115 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyWriter.java x: 164 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisConnectionOptions.java x: 88 lines of code y: 7 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java x: 85 lines of code y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java x: 10 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/RowDataDeserializationSchema.java x: 25 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/SimpleListDeserializationSchema.java x: 17 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/RespContent.java x: 112 lines of code y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecordSerializer.java x: 13 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RecordWithMetaSerializer.java x: 29 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowDataSerializer.java x: 203 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowSerializer.java x: 74 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/SimpleStringSerializer.java x: 11 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java x: 99 lines of code y: 7 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java x: 127 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/CreateTableException.java x: 9 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java x: 15 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisSystemException.java x: 12 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/LookupMetrics.java x: 26 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java x: 129 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java x: 108 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/ResponseUtil.java x: 23 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/RecordWithMeta.java x: 47 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/util/IPUtils.java x: 126 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java x: 93 lines of code y: 7 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java x: 89 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommitter.java x: 136 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java x: 355 lines of code y: 12 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresSchema.java x: 22 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/CopyLoadException.java x: 22 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisAbstractCommittable.java x: 2 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java x: 51 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BackoffAndRetryUtils.java x: 43 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/CopyCommittableSerializer.java x: 40 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/models/BaseResponse.java x: 18 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisAbstractWriter.java x: 6 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/WriteMode.java x: 13 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriteMetrics.java x: 275 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/ChangeEvent.java x: 3 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecord.java x: 55 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/flink/table/runtime/arrow/serializers/ArrowSerializer.java x: 84 lines of code y: 1 # changes tools/maven/suppressions.xml x: 7 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/connection/JdbcConnectionProvider.java x: 6 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisJdbcLookupReader.java x: 106 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java x: 187 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/LookupSchema.java x: 69 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Record.java x: 43 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java x: 109 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittableSerializer.java x: 34 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/EscapeHandler.java x: 39 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpGetWithEntity.java x: 14 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/CacheRecordBuffer.java x: 87 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java x: 63 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterStateSerializer.java x: 41 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java x: 146 lines of code y: 7 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisInternalException.java x: 14 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java x: 2 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/Routing.java x: 38 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners/DorisSplitAssigner.java x: 11 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/PendingSplitsCheckpointSerializer.java x: 80 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplitState.java x: 10 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/util/ErrorMessages.java x: 13 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/EventType.java x: 5 lines of code y: 1 # changes custom_env.sh.tpl x: 2 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Get.java x: 19 lines of code y: 1 # changes
47.0
# changes
  min: 1.0
  average: 5.85
  25th percentile: 2.0
  median: 4.0
  75th percentile: 6.0
  max: 47.0
0 639.0
lines of code
min: 2.0 | average: 104.26 | 25th percentile: 23.0 | median: 70.0 | 75th percentile: 139.75 | max: 639.0

Number of Contributors vs. Number of Changes: 196 points

flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java x: 3 # contributors y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java x: 5 # contributors y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 10 # contributors y: 47 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java x: 7 # contributors y: 10 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java x: 3 # contributors y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java x: 4 # contributors y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java x: 4 # contributors y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java x: 1 # contributors y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java x: 3 # contributors y: 8 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java x: 3 # contributors y: 15 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java x: 2 # contributors y: 7 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 7 # contributors y: 23 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java x: 1 # contributors y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java x: 6 # contributors y: 28 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java x: 7 # contributors y: 29 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java x: 5 # contributors y: 8 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 6 # contributors y: 25 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java x: 7 # contributors y: 22 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 12 # contributors y: 25 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java x: 4 # contributors y: 8 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java x: 4 # contributors y: 12 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java x: 11 # contributors y: 26 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/ValueReader.java x: 2 # contributors y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java x: 2 # contributors y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java x: 3 # contributors y: 7 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactory.java x: 2 # contributors y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java x: 3 # contributors y: 16 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java x: 3 # contributors y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java x: 4 # contributors y: 10 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java x: 7 # contributors y: 19 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/ChangeStreamConstant.java x: 2 # contributors y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java x: 7 # contributors y: 14 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SQLParserSchemaManager.java x: 2 # contributors y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java x: 3 # contributors y: 11 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java x: 5 # contributors y: 13 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java x: 4 # contributors y: 18 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSource.java x: 4 # contributors y: 9 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java x: 4 # contributors y: 11 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java x: 6 # contributors y: 23 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeHelper.java x: 3 # contributors y: 10 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java x: 4 # contributors y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java x: 3 # contributors y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisSink.java x: 3 # contributors y: 13 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeManager.java x: 3 # contributors y: 9 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java x: 5 # contributors y: 20 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java x: 5 # contributors y: 9 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java x: 1 # contributors y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java x: 8 # contributors y: 25 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java x: 5 # contributors y: 17 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java x: 6 # contributors y: 15 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImpl.java x: 1 # contributors y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java x: 4 # contributors y: 7 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java x: 5 # contributors y: 12 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java x: 5 # contributors y: 7 # changes
47.0
# changes
  min: 1.0
  average: 5.85
  25th percentile: 2.0
  median: 4.0
  75th percentile: 6.0
  max: 47.0
0 12.0
# contributors
min: 1.0 | average: 2.83 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 3.0 | max: 12.0

Number of Contributors vs. File Size: 196 points

flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java x: 3 # contributors y: 105 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java x: 5 # contributors y: 118 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 10 # contributors y: 475 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java x: 7 # contributors y: 205 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java x: 3 # contributors y: 130 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java x: 4 # contributors y: 186 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java x: 4 # contributors y: 116 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java x: 3 # contributors y: 209 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java x: 1 # contributors y: 63 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java x: 1 # contributors y: 30 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java x: 3 # contributors y: 156 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java x: 3 # contributors y: 289 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java x: 2 # contributors y: 98 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 7 # contributors y: 339 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java x: 1 # contributors y: 22 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java x: 6 # contributors y: 482 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java x: 7 # contributors y: 355 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java x: 5 # contributors y: 26 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java x: 4 # contributors y: 103 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java x: 4 # contributors y: 42 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 6 # contributors y: 279 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java x: 7 # contributors y: 520 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 12 # contributors y: 599 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java x: 4 # contributors y: 35 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java x: 4 # contributors y: 274 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java x: 11 # contributors y: 639 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/ValueReader.java x: 2 # contributors y: 35 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java x: 2 # contributors y: 7 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java x: 3 # contributors y: 208 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactory.java x: 2 # contributors y: 207 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java x: 3 # contributors y: 269 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java x: 3 # contributors y: 57 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter/TableNameConverter.java x: 1 # contributors y: 37 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java x: 2 # contributors y: 23 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java x: 4 # contributors y: 75 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java x: 4 # contributors y: 142 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisFlightValueReader.java x: 2 # contributors y: 184 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisValueReader.java x: 3 # contributors y: 246 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java x: 7 # contributors y: 223 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/ChangeStreamConstant.java x: 2 # contributors y: 21 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/BackendV2.java x: 3 # contributors y: 52 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java x: 3 # contributors y: 87 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java x: 3 # contributors y: 31 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java x: 3 # contributors y: 68 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java x: 3 # contributors y: 34 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java x: 7 # contributors y: 159 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SQLParserSchemaManager.java x: 2 # contributors y: 343 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java x: 3 # contributors y: 63 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/CdcSchemaChange.java x: 2 # contributors y: 9 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java x: 5 # contributors y: 143 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java x: 4 # contributors y: 220 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java x: 3 # contributors y: 132 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSource.java x: 4 # contributors y: 147 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java x: 2 # contributors y: 42 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisExpressionVisitor.java x: 2 # contributors y: 126 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DorisTableConfig.java x: 2 # contributors y: 78 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/JdbcSourceSchema.java x: 3 # contributors y: 93 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java x: 4 # contributors y: 95 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java x: 4 # contributors y: 213 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java x: 6 # contributors y: 196 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeHelper.java x: 3 # contributors y: 177 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java x: 4 # contributors y: 222 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java x: 3 # contributors y: 26 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisSink.java x: 3 # contributors y: 148 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/IllegalArgumentException.java x: 2 # contributors y: 12 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeManager.java x: 3 # contributors y: 311 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSyncConfig.java x: 3 # contributors y: 66 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumerator.java x: 2 # contributors y: 58 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceReader.java x: 2 # contributors y: 50 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceSplitReader.java x: 3 # contributors y: 80 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java x: 5 # contributors y: 151 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java x: 2 # contributors y: 51 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java x: 5 # contributors y: 184 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchBufferHttpEntity.java x: 1 # contributors y: 48 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchBufferStream.java x: 1 # contributors y: 47 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java x: 3 # contributors y: 98 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchRecordBuffer.java x: 1 # contributors y: 113 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java x: 1 # contributors y: 367 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisStreamOptions.java x: 4 # contributors y: 106 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/SchemaUtils.java x: 3 # contributors y: 45 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSplitRecords.java x: 3 # contributors y: 48 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java x: 8 # contributors y: 240 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java x: 1 # contributors y: 208 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java x: 5 # contributors y: 227 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java x: 4 # contributors y: 193 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Schema.java x: 1 # contributors y: 31 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/CopySQLBuilder.java x: 2 # contributors y: 68 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumDataChange.java x: 3 # contributors y: 95 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java x: 4 # contributors y: 478 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeUtils.java x: 2 # contributors y: 71 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceConnector.java x: 2 # contributors y: 16 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DateConverter.java x: 1 # contributors y: 104 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Type.java x: 1 # contributors y: 71 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java x: 2 # contributors y: 141 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java x: 2 # contributors y: 118 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDateConverter.java x: 2 # contributors y: 104 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDateConverter.java x: 2 # contributors y: 85 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/deserialize/DorisJsonDebeziumDeserializationSchema.java x: 1 # contributors y: 165 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java x: 6 # contributors y: 230 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeMode.java x: 1 # contributors y: 12 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImpl.java x: 1 # contributors y: 115 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyWriter.java x: 2 # contributors y: 164 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java x: 4 # contributors y: 85 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java x: 4 # contributors y: 10 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/RowDataDeserializationSchema.java x: 3 # contributors y: 25 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/SimpleListDeserializationSchema.java x: 3 # contributors y: 17 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/RespContent.java x: 5 # contributors y: 112 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecordSerializer.java x: 3 # contributors y: 13 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RecordWithMetaSerializer.java x: 2 # contributors y: 29 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowDataSerializer.java x: 3 # contributors y: 203 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowSerializer.java x: 2 # contributors y: 74 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java x: 4 # contributors y: 99 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java x: 2 # contributors y: 15 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/StreamLoadException.java x: 3 # contributors y: 9 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/LookupMetrics.java x: 1 # contributors y: 26 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java x: 2 # contributors y: 129 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java x: 2 # contributors y: 108 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/RecordWithMeta.java x: 2 # contributors y: 47 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/util/IPUtils.java x: 1 # contributors y: 126 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java x: 4 # contributors y: 93 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleSchema.java x: 4 # contributors y: 31 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java x: 4 # contributors y: 89 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommitter.java x: 1 # contributors y: 136 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java x: 5 # contributors y: 355 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresSchema.java x: 3 # contributors y: 22 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisAbstractCommittable.java x: 1 # contributors y: 2 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BackoffAndRetryUtils.java x: 1 # contributors y: 43 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/CopyCommittableSerializer.java x: 1 # contributors y: 40 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/models/BaseResponse.java x: 1 # contributors y: 18 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisAbstractWriter.java x: 1 # contributors y: 6 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/WriteMode.java x: 1 # contributors y: 13 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriteMetrics.java x: 1 # contributors y: 275 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/ChangeEvent.java x: 1 # contributors y: 3 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecord.java x: 3 # contributors y: 55 lines of code flink-doris-connector/src/main/java/org/apache/flink/table/runtime/arrow/serializers/ArrowSerializer.java x: 1 # contributors y: 84 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java x: 2 # contributors y: 187 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Record.java x: 2 # contributors y: 43 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java x: 2 # contributors y: 109 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/EscapeHandler.java x: 3 # contributors y: 39 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/CacheRecordBuffer.java x: 2 # contributors y: 87 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterStateSerializer.java x: 3 # contributors y: 41 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java x: 5 # contributors y: 146 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java x: 3 # contributors y: 2 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/Routing.java x: 2 # contributors y: 38 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisRecordEmitter.java x: 2 # contributors y: 31 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisLookupReader.java x: 1 # contributors y: 10 lines of code custom_env.sh.tpl x: 2 # contributors y: 2 lines of code
639.0
lines of code
  min: 2.0
  average: 104.26
  25th percentile: 23.0
  median: 70.0
  75th percentile: 139.75
  max: 639.0
0 12.0
# contributors
min: 1.0 | average: 2.83 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 3.0 | max: 12.0