apache / doris-kafka-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 114 files with 6,050 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)
    • 7 files changed 6-20 times (1,669 lines of code)
    • 107 files changed 1-5 times (4,381 lines of code)
0% | 0% | 0% | 27% | 72%
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 114 files with 6,050 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 3 files changed by 6-10 contributors (675 lines of code)
    • 56 files changed by 2-5 contributors (3,773 lines of code)
    • 55 files changed by 1 contributor (1,602 lines of code)
0% | 0% | 11% | 62% | 26%
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, sql, json, yaml, properties, sh, md, avsc, txt, gitignore, xml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 27% | 72%
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
src0% | 0% | 0% | 27% | 72%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
DorisOptions.java
in src/main/java/org/apache/doris/kafka/connector/cfg
 288 40 2024-03-04 2025-04-29 15 6 morningman@163.com 59386838+chuang-wang-pre@us...
DorisSinkConnectorConfig.java
in src/main/java/org/apache/doris/kafka/connector/cfg
 281 7 2024-03-04 2025-04-29 12 5 morningman@163.com 59386838+chuang-wang-pre@us...
RecordService.java
in src/main/java/org/apache/doris/kafka/connector/converter
 290 19 2024-03-04 2025-04-24 11 5 morningman@163.com 676366545@qq.com
ConfigCheckUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 270 10 2024-03-04 2025-04-29 10 6 morningman@163.com 59386838+chuang-wang-pre@us...
StreamLoadWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 163 10 2024-03-04 2025-01-22 8 4 morningman@163.com 59386838+chuang-wang-pre@us...
DorisDefaultSinkService.java
in src/main/java/org/apache/doris/kafka/connector/service
 225 13 2024-03-04 2025-04-29 8 4 morningman@163.com 59386838+chuang-wang-pre@us...
DorisWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 152 11 2024-03-04 2025-04-11 7 5 morningman@163.com 676366545@qq.com
DorisSinkTask.java
in src/main/java/org/apache/doris/kafka/connector
 86 8 2024-03-04 2025-04-25 5 5 morningman@163.com 59386838+chuang-wang-pre@us...
DorisStreamLoad.java
in src/main/java/org/apache/doris/kafka/connector/writer/load
 117 6 2024-03-04 2025-04-11 5 6 morningman@163.com 676366545@qq.com
CopyIntoWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 128 9 2024-03-04 2024-12-30 5 4 morningman@163.com 59386838+chuang-wang-pre@us...
RecordDescriptor.java
in src/main/java/org/apache/doris/kafka/connector/converter
 169 27 2024-04-15 2024-12-26 5 2 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
LabelGenerator.java
in src/main/java/org/apache/doris/kafka/connector/writer
 34 3 2024-03-04 2025-01-22 4 4 morningman@163.com 59386838+chuang-wang-pre@us...
DorisSinkConnector.java
in src/main/java/org/apache/doris/kafka/connector
 57 7 2024-03-04 2025-01-22 4 4 morningman@163.com 59386838+chuang-wang-pre@us...
DorisSystemService.java
in src/main/java/org/apache/doris/kafka/connector/service
 82 7 2024-05-08 2024-09-10 4 2 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
RestService.java
in src/main/java/org/apache/doris/kafka/connector/service
 293 11 2024-03-04 2025-01-22 4 4 morningman@163.com 59386838+chuang-wang-pre@us...
LoadConstants.java
in src/main/java/org/apache/doris/kafka/connector/writer
 9 - 2024-03-04 2024-07-09 3 4 morningman@163.com 31833513+vinlee19@users.nor...
Version.java
in src/main/java/org/apache/doris/kafka/connector/utils
 10 1 2024-03-04 2025-04-29 3 4 morningman@163.com 676366545@qq.com
Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type
 13 1 2024-04-15 2024-06-06 3 2 46414265+dongliang-0@users.... 31833513+vinlee19@users.nor...
MicroTimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 15 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
NanoTimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 15 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
MicroTimestampType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 15 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
TimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 15 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
NanoTimestampType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 16 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DateType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 25 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectDateType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 25 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectTimestampType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 25 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectTimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 31 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
AbstractType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type
 37 8 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
FileNameUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 53 7 2024-03-04 2024-06-21 3 3 morningman@163.com 46414265+dongliang-0@users....
JdbcConnectionProvider.java
in src/main/java/org/apache/doris/kafka/connector/connection
 54 3 2024-03-04 2025-01-22 3 4 morningman@163.com 59386838+chuang-wang-pre@us...
DorisCommitter.java
in src/main/java/org/apache/doris/kafka/connector/writer/commit
 103 3 2024-03-04 2025-01-22 3 4 morningman@163.com 59386838+chuang-wang-pre@us...
DorisConnectMonitor.java
in src/main/java/org/apache/doris/kafka/connector/metrics
 121 9 2024-03-04 2025-01-22 3 4 morningman@163.com 59386838+chuang-wang-pre@us...
LoadStatus.java
in src/main/java/org/apache/doris/kafka/connector/writer
 5 - 2024-03-04 2024-10-21 2 3 morningman@163.com 46414265+dongliang-0@users....
AbstractDateType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type
 9 1 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DorisSinkServiceFactory.java
in src/main/java/org/apache/doris/kafka/connector/service
 9 1 2024-03-04 2025-04-25 2 3 morningman@163.com 59386838+chuang-wang-pre@us...
ResponseUtil.java
in src/main/java/org/apache/doris/kafka/connector/writer
 10 1 2024-03-04 2024-10-21 2 3 morningman@163.com 46414265+dongliang-0@users....
ConnectBooleanType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 14 1 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DorisSinkService.java
in src/main/java/org/apache/doris/kafka/connector/service
 15 - 2024-03-04 2024-10-21 2 3 morningman@163.com 46414265+dongliang-0@users....
SchemaEvolutionMode.java
in src/main/java/org/apache/doris/kafka/connector/converter/schema
 18 2 2024-05-16 2024-06-12 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectFloat32Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectFloat64Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectInt16Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectInt8Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectInt64Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectInt32Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectMapToConnectStringType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConverterMode.java
in src/main/java/org/apache/doris/kafka/connector/converter
 18 2 2024-04-10 2024-06-12 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DeliveryGuarantee.java
in src/main/java/org/apache/doris/kafka/connector/writer
 18 2 2024-03-04 2024-06-12 2 3 morningman@163.com 46414265+dongliang-0@users....
LoadModel.java
in src/main/java/org/apache/doris/kafka/connector/writer/load
 18 2 2024-03-04 2024-06-12 2 3 morningman@163.com 46414265+dongliang-0@users....
AbstractTimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type
 20 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
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
DorisOptions.java
in src/main/java/org/apache/doris/kafka/connector/cfg
 288 40 2024-03-04 2025-04-29 15 6 morningman@163.com 59386838+chuang-wang-pre@us...
ConfigCheckUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 270 10 2024-03-04 2025-04-29 10 6 morningman@163.com 59386838+chuang-wang-pre@us...
DorisStreamLoad.java
in src/main/java/org/apache/doris/kafka/connector/writer/load
 117 6 2024-03-04 2025-04-11 5 6 morningman@163.com 676366545@qq.com
DorisSinkConnectorConfig.java
in src/main/java/org/apache/doris/kafka/connector/cfg
 281 7 2024-03-04 2025-04-29 12 5 morningman@163.com 59386838+chuang-wang-pre@us...
RecordService.java
in src/main/java/org/apache/doris/kafka/connector/converter
 290 19 2024-03-04 2025-04-24 11 5 morningman@163.com 676366545@qq.com
DorisWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 152 11 2024-03-04 2025-04-11 7 5 morningman@163.com 676366545@qq.com
DorisSinkTask.java
in src/main/java/org/apache/doris/kafka/connector
 86 8 2024-03-04 2025-04-25 5 5 morningman@163.com 59386838+chuang-wang-pre@us...
DorisDefaultSinkService.java
in src/main/java/org/apache/doris/kafka/connector/service
 225 13 2024-03-04 2025-04-29 8 4 morningman@163.com 59386838+chuang-wang-pre@us...
StreamLoadWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 163 10 2024-03-04 2025-01-22 8 4 morningman@163.com 59386838+chuang-wang-pre@us...
CopyIntoWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 128 9 2024-03-04 2024-12-30 5 4 morningman@163.com 59386838+chuang-wang-pre@us...
RestService.java
in src/main/java/org/apache/doris/kafka/connector/service
 293 11 2024-03-04 2025-01-22 4 4 morningman@163.com 59386838+chuang-wang-pre@us...
DorisSinkConnector.java
in src/main/java/org/apache/doris/kafka/connector
 57 7 2024-03-04 2025-01-22 4 4 morningman@163.com 59386838+chuang-wang-pre@us...
LabelGenerator.java
in src/main/java/org/apache/doris/kafka/connector/writer
 34 3 2024-03-04 2025-01-22 4 4 morningman@163.com 59386838+chuang-wang-pre@us...
DorisConnectMonitor.java
in src/main/java/org/apache/doris/kafka/connector/metrics
 121 9 2024-03-04 2025-01-22 3 4 morningman@163.com 59386838+chuang-wang-pre@us...
JdbcConnectionProvider.java
in src/main/java/org/apache/doris/kafka/connector/connection
 54 3 2024-03-04 2025-01-22 3 4 morningman@163.com 59386838+chuang-wang-pre@us...
Version.java
in src/main/java/org/apache/doris/kafka/connector/utils
 10 1 2024-03-04 2025-04-29 3 4 morningman@163.com 676366545@qq.com
LoadConstants.java
in src/main/java/org/apache/doris/kafka/connector/writer
 9 - 2024-03-04 2024-07-09 3 4 morningman@163.com 31833513+vinlee19@users.nor...
DorisCommitter.java
in src/main/java/org/apache/doris/kafka/connector/writer/commit
 103 3 2024-03-04 2025-01-22 3 4 morningman@163.com 59386838+chuang-wang-pre@us...
FileNameUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 53 7 2024-03-04 2024-06-21 3 3 morningman@163.com 46414265+dongliang-0@users....
MetricsJmxReporter.java
in src/main/java/org/apache/doris/kafka/connector/metrics
 66 6 2024-03-04 2025-01-22 2 3 morningman@163.com 59386838+chuang-wang-pre@us...
RespContent.java
in src/main/java/org/apache/doris/kafka/connector/model
 74 8 2024-03-04 2025-04-11 2 3 morningman@163.com 676366545@qq.com
HttpPutBuilder.java
in src/main/java/org/apache/doris/kafka/connector/utils
 89 15 2024-03-04 2024-06-06 2 3 morningman@163.com 46414265+dongliang-0@users....
BackoffAndRetryUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 33 1 2024-03-04 2025-01-22 2 3 morningman@163.com 59386838+chuang-wang-pre@us...
BackendUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 47 4 2024-03-04 2024-06-21 2 3 morningman@163.com 46414265+dongliang-0@users....
DorisSinkService.java
in src/main/java/org/apache/doris/kafka/connector/service
 15 - 2024-03-04 2024-10-21 2 3 morningman@163.com 46414265+dongliang-0@users....
DorisSinkServiceFactory.java
in src/main/java/org/apache/doris/kafka/connector/service
 9 1 2024-03-04 2025-04-25 2 3 morningman@163.com 59386838+chuang-wang-pre@us...
LoadStatus.java
in src/main/java/org/apache/doris/kafka/connector/writer
 5 - 2024-03-04 2024-10-21 2 3 morningman@163.com 46414265+dongliang-0@users....
ResponseUtil.java
in src/main/java/org/apache/doris/kafka/connector/writer
 10 1 2024-03-04 2024-10-21 2 3 morningman@163.com 46414265+dongliang-0@users....
LoadModel.java
in src/main/java/org/apache/doris/kafka/connector/writer/load
 18 2 2024-03-04 2024-06-12 2 3 morningman@163.com 46414265+dongliang-0@users....
CopyLoad.java
in src/main/java/org/apache/doris/kafka/connector/writer/load
 232 9 2024-03-04 2025-01-22 2 3 morningman@163.com 59386838+chuang-wang-pre@us...
DeliveryGuarantee.java
in src/main/java/org/apache/doris/kafka/connector/writer
 18 2 2024-03-04 2024-06-12 2 3 morningman@163.com 46414265+dongliang-0@users....
RecordDescriptor.java
in src/main/java/org/apache/doris/kafka/connector/converter
 169 27 2024-04-15 2024-12-26 5 2 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DorisSystemService.java
in src/main/java/org/apache/doris/kafka/connector/service
 82 7 2024-05-08 2024-09-10 4 2 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type
 13 1 2024-04-15 2024-06-06 3 2 46414265+dongliang-0@users.... 31833513+vinlee19@users.nor...
GeoUtils.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/util
 38 2 2024-06-06 2024-11-21 2 2 31833513+vinlee19@users.nor... 46414265+dongliang-0@users....
SchemaChangeManager.java
in src/main/java/org/apache/doris/kafka/connector/converter/schema
 149 11 2024-05-16 2024-06-04 2 2 46414265+dongliang-0@users.... 31833513+vinlee19@users.nor...
RecordTypeRegister.java
in src/main/java/org/apache/doris/kafka/connector/converter
 92 4 2024-04-15 2024-06-06 2 2 46414265+dongliang-0@users.... 31833513+vinlee19@users.nor...
MetricsUtil.java
in src/main/java/org/apache/doris/kafka/connector/metrics
 18 1 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
ConnectionProvider.java
in src/main/java/org/apache/doris/kafka/connector/connection
 6 - 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
LoadOperation.java
in src/main/java/org/apache/doris/kafka/connector/model
 8 - 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
CopyIntoResp.java
in src/main/java/org/apache/doris/kafka/connector/model
 18 3 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
BaseResponse.java
in src/main/java/org/apache/doris/kafka/connector/model
 18 3 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
KafkaRespContent.java
in src/main/java/org/apache/doris/kafka/connector/model
 31 8 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
BackendV2.java
in src/main/java/org/apache/doris/kafka/connector/model
 51 10 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
HttpUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 19 2 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
HttpPostBuilder.java
in src/main/java/org/apache/doris/kafka/connector/utils
 44 6 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
ArgumentsException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 13 4 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
DataFormatException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 13 4 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
CopyLoadException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 13 4 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
DorisException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 13 4 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@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
DorisAvroConverter.java
in src/main/java/org/apache/doris/kafka/connector/decode/avro
 142 6 2024-06-26 2024-10-21 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
Field.java
in src/main/java/org/apache/doris/kafka/connector/model/doris
 105 17 2024-05-08 2024-05-08 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DateTimeUtils.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/util
 77 18 2024-05-29 2024-05-29 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ArrayType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 77 4 2024-06-06 2024-06-06 1 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...
Schema.java
in src/main/java/org/apache/doris/kafka/connector/model/doris
 74 15 2024-05-08 2024-05-08 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
TableDescriptor.java
in src/main/java/org/apache/doris/kafka/connector/model
 64 14 2024-05-08 2024-05-08 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ColumnDescriptor.java
in src/main/java/org/apache/doris/kafka/connector/model
 57 11 2024-05-08 2024-05-08 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DorisJsonSchema.java
in src/main/java/org/apache/doris/kafka/connector/decode
 57 11 2024-06-26 2024-06-26 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectBytesType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 40 3 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
VariableScaleDecimalType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 39 3 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
AbstractType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type
 37 8 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ZonedTimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 33 1 2024-04-15 2024-09-10 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectTimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 31 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
SchemaUtils.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/util
 29 5 2024-05-29 2024-05-29 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectDecimalType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 29 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ZonedTimestampType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 28 1 2024-04-15 2024-04-15 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
AbstractTemporalType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type
 26 2 2024-04-15 2024-04-15 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectTimestampType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 25 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectDateType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 25 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DateType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 25 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DorisType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/doris
 24 - 2024-05-16 2024-05-16 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectStringType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 24 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
SchemaChangeException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 22 5 2024-05-08 2024-05-08 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
AbstractDebeziumTimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 22 1 2024-04-15 2024-05-08 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
PointType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 22 1 2024-06-06 2024-06-06 1 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...
GeometryType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 22 1 2024-06-06 2024-06-06 1 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...
GroupCommitMode.java
in src/main/java/org/apache/doris/kafka/connector/writer/load
 21 3 2024-07-09 2024-07-09 1 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...
AbstractTimestampType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type
 20 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
AbstractTimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type
 20 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
AbstractDebeziumTimestampType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 20 1 2024-04-15 2024-04-15 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConverterMode.java
in src/main/java/org/apache/doris/kafka/connector/converter
 18 2 2024-04-10 2024-06-12 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectMapToConnectStringType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectInt32Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectInt64Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectInt8Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectInt16Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectFloat64Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectFloat32Type.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 2 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
AbstractConnectMapType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 18 1 2024-04-15 2024-04-15 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
SchemaEvolutionMode.java
in src/main/java/org/apache/doris/kafka/connector/converter/schema
 18 2 2024-05-16 2024-06-12 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
TimestampType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 16 1 2024-04-15 2024-04-15 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
NanoTimestampType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 16 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
BehaviorOnNullValues.java
in src/main/java/org/apache/doris/kafka/connector/model
 15 1 2025-04-29 2025-04-29 1 1 59386838+chuang-wang-pre@us... 59386838+chuang-wang-pre@us...
TimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 15 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
MicroTimestampType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 15 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
NanoTimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 15 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
MicroTimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 15 1 2024-04-15 2024-05-29 3 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DorisConverter.java
in src/main/java/org/apache/doris/kafka/connector/decode
 14 1 2024-06-26 2024-06-26 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
ConnectBooleanType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 14 1 2024-04-15 2024-05-16 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DataDecodeException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 12 3 2024-06-26 2024-06-26 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
Correlations

File Size vs. Number of Changes: 114 points

src/main/java/org/apache/doris/kafka/connector/utils/Version.java x: 10 lines of code y: 3 # changes src/main/java/org/apache/doris/kafka/connector/cfg/DorisOptions.java x: 288 lines of code y: 15 # changes src/main/java/org/apache/doris/kafka/connector/cfg/DorisSinkConnectorConfig.java x: 281 lines of code y: 12 # changes src/main/java/org/apache/doris/kafka/connector/model/BehaviorOnNullValues.java x: 15 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java x: 225 lines of code y: 8 # changes src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java x: 270 lines of code y: 10 # changes src/main/java/org/apache/doris/kafka/connector/DorisSinkTask.java x: 86 lines of code y: 5 # changes src/main/java/org/apache/doris/kafka/connector/service/DorisSinkServiceFactory.java x: 9 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java x: 290 lines of code y: 11 # changes src/main/java/org/apache/doris/kafka/connector/model/RespContent.java x: 74 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java x: 152 lines of code y: 7 # changes src/main/java/org/apache/doris/kafka/connector/writer/load/DorisStreamLoad.java x: 117 lines of code y: 5 # changes src/main/java/org/apache/doris/kafka/connector/DorisSinkConnector.java x: 57 lines of code y: 4 # changes src/main/java/org/apache/doris/kafka/connector/connection/JdbcConnectionProvider.java x: 54 lines of code y: 3 # changes src/main/java/org/apache/doris/kafka/connector/metrics/DorisConnectMonitor.java x: 121 lines of code y: 3 # changes src/main/java/org/apache/doris/kafka/connector/metrics/MetricsJmxReporter.java x: 66 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/service/RestService.java x: 293 lines of code y: 4 # changes src/main/java/org/apache/doris/kafka/connector/utils/BackoffAndRetryUtils.java x: 33 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/writer/LabelGenerator.java x: 34 lines of code y: 4 # changes src/main/java/org/apache/doris/kafka/connector/writer/StreamLoadWriter.java x: 163 lines of code y: 8 # changes src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommitter.java x: 103 lines of code y: 3 # changes src/main/java/org/apache/doris/kafka/connector/writer/load/CopyLoad.java x: 232 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/writer/CopyIntoWriter.java x: 128 lines of code y: 5 # changes src/main/java/org/apache/doris/kafka/connector/converter/RecordDescriptor.java x: 169 lines of code y: 5 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/util/GeoUtils.java x: 38 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/service/DorisSinkService.java x: 15 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/writer/LoadStatus.java x: 5 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/writer/ResponseUtil.java x: 10 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/decode/avro/DorisAvroConverter.java x: 142 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/service/DorisSystemService.java x: 82 lines of code y: 4 # changes src/main/java/org/apache/doris/kafka/connector/writer/LoadConstants.java x: 9 lines of code y: 3 # changes src/main/java/org/apache/doris/kafka/connector/writer/load/GroupCommitMode.java x: 21 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/decode/DorisConverter.java x: 14 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/decode/DorisJsonSchema.java x: 57 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/exception/DataDecodeException.java x: 12 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/utils/BackendUtils.java x: 47 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/utils/FileNameUtils.java x: 53 lines of code y: 3 # changes src/main/java/org/apache/doris/kafka/connector/converter/ConverterMode.java x: 18 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/converter/RecordTypeRegister.java x: 92 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractGeometryType.java x: 9 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/Type.java x: 13 lines of code y: 3 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ArrayType.java x: 77 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/GeographyType.java x: 10 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/GeometryType.java x: 22 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/utils/HttpPutBuilder.java x: 89 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/converter/schema/SchemaChangeManager.java x: 149 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractType.java x: 37 lines of code y: 3 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectDateType.java x: 25 lines of code y: 3 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectTimeType.java x: 31 lines of code y: 3 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/MicroTimeType.java x: 15 lines of code y: 3 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/NanoTimestampType.java x: 16 lines of code y: 3 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/util/SchemaUtils.java x: 29 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractTimeType.java x: 20 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectBooleanType.java x: 14 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectBytesType.java x: 40 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectDecimalType.java x: 29 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectStringType.java x: 24 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/VariableScaleDecimalType.java x: 39 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/doris/DorisType.java x: 24 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/doris/DorisTypeProperties.java x: 7 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/AbstractDebeziumTimeType.java x: 22 lines of code y: 2 # changes src/main/java/org/apache/doris/kafka/connector/model/TableDescriptor.java x: 64 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/model/doris/Field.java x: 105 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/model/doris/Schema.java x: 74 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractTemporalType.java x: 26 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/connect/AbstractConnectMapType.java x: 18 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/connect/AbstractConnectSchemaType.java x: 3 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/AbstractDebeziumTimestampType.java x: 20 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/TimestampType.java x: 16 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ZonedTimestampType.java x: 28 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/connection/ConnectionProvider.java x: 6 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/exception/ArgumentsException.java x: 13 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/model/BackendV2.java x: 51 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/model/KafkaRespContent.java x: 31 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/model/LoadOperation.java x: 8 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/utils/HttpPostBuilder.java x: 44 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/utils/HttpUtils.java x: 19 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/writer/CopySQLBuilder.java x: 45 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/writer/PartitionBuffer.java x: 55 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/writer/RecordBuffer.java x: 30 lines of code y: 1 # changes src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommittable.java x: 78 lines of code y: 1 # changes
15.0
# changes
  min: 1.0
  average: 2.41
  25th percentile: 1.0
  median: 2.0
  75th percentile: 3.0
  max: 15.0
0 293.0
lines of code
min: 3.0 | average: 53.07 | 25th percentile: 15.0 | median: 23.0 | 75th percentile: 58.75 | max: 293.0

Number of Contributors vs. Number of Changes: 114 points

src/main/java/org/apache/doris/kafka/connector/utils/Version.java x: 4 # contributors y: 3 # changes src/main/java/org/apache/doris/kafka/connector/cfg/DorisOptions.java x: 6 # contributors y: 15 # changes src/main/java/org/apache/doris/kafka/connector/cfg/DorisSinkConnectorConfig.java x: 5 # contributors y: 12 # changes src/main/java/org/apache/doris/kafka/connector/model/BehaviorOnNullValues.java x: 1 # contributors y: 1 # changes src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java x: 4 # contributors y: 8 # changes src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java x: 6 # contributors y: 10 # changes src/main/java/org/apache/doris/kafka/connector/DorisSinkTask.java x: 5 # contributors y: 5 # changes src/main/java/org/apache/doris/kafka/connector/service/DorisSinkServiceFactory.java x: 3 # contributors y: 2 # changes src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java x: 5 # contributors y: 11 # changes src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java x: 5 # contributors y: 7 # changes src/main/java/org/apache/doris/kafka/connector/writer/load/DorisStreamLoad.java x: 6 # contributors y: 5 # changes src/main/java/org/apache/doris/kafka/connector/DorisSinkConnector.java x: 4 # contributors y: 4 # changes src/main/java/org/apache/doris/kafka/connector/writer/CopyIntoWriter.java x: 4 # contributors y: 5 # changes src/main/java/org/apache/doris/kafka/connector/converter/RecordDescriptor.java x: 2 # contributors y: 5 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/util/GeoUtils.java x: 2 # contributors y: 2 # changes src/main/java/org/apache/doris/kafka/connector/decode/avro/DorisAvroConverter.java x: 1 # contributors y: 2 # changes src/main/java/org/apache/doris/kafka/connector/service/DorisSystemService.java x: 2 # contributors y: 4 # changes src/main/java/org/apache/doris/kafka/connector/utils/FileNameUtils.java x: 3 # contributors y: 3 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/Type.java x: 2 # contributors y: 3 # changes src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractType.java x: 1 # contributors y: 3 # changes src/main/java/org/apache/doris/kafka/connector/connection/ConnectionProvider.java x: 2 # contributors y: 1 # changes
15.0
# changes
  min: 1.0
  average: 2.41
  25th percentile: 1.0
  median: 2.0
  75th percentile: 3.0
  max: 15.0
0 6.0
# contributors
min: 1.0 | average: 2.04 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 3.0 | max: 6.0

Number of Contributors vs. File Size: 114 points

src/main/java/org/apache/doris/kafka/connector/utils/Version.java x: 4 # contributors y: 10 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisOptions.java x: 6 # contributors y: 288 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisSinkConnectorConfig.java x: 5 # contributors y: 281 lines of code src/main/java/org/apache/doris/kafka/connector/model/BehaviorOnNullValues.java x: 1 # contributors y: 15 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java x: 4 # contributors y: 225 lines of code src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java x: 6 # contributors y: 270 lines of code src/main/java/org/apache/doris/kafka/connector/DorisSinkTask.java x: 5 # contributors y: 86 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisSinkServiceFactory.java x: 3 # contributors y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java x: 5 # contributors y: 290 lines of code src/main/java/org/apache/doris/kafka/connector/model/RespContent.java x: 3 # contributors y: 74 lines of code src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java x: 5 # contributors y: 152 lines of code src/main/java/org/apache/doris/kafka/connector/writer/load/DorisStreamLoad.java x: 6 # contributors y: 117 lines of code src/main/java/org/apache/doris/kafka/connector/DorisSinkConnector.java x: 4 # contributors y: 57 lines of code src/main/java/org/apache/doris/kafka/connector/connection/JdbcConnectionProvider.java x: 4 # contributors y: 54 lines of code src/main/java/org/apache/doris/kafka/connector/metrics/DorisConnectMonitor.java x: 4 # contributors y: 121 lines of code src/main/java/org/apache/doris/kafka/connector/metrics/MetricsJmxReporter.java x: 3 # contributors y: 66 lines of code src/main/java/org/apache/doris/kafka/connector/service/RestService.java x: 4 # contributors y: 293 lines of code src/main/java/org/apache/doris/kafka/connector/utils/BackoffAndRetryUtils.java x: 3 # contributors y: 33 lines of code src/main/java/org/apache/doris/kafka/connector/writer/LabelGenerator.java x: 4 # contributors y: 34 lines of code src/main/java/org/apache/doris/kafka/connector/writer/StreamLoadWriter.java x: 4 # contributors y: 163 lines of code src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommitter.java x: 4 # contributors y: 103 lines of code src/main/java/org/apache/doris/kafka/connector/writer/load/CopyLoad.java x: 3 # contributors y: 232 lines of code src/main/java/org/apache/doris/kafka/connector/writer/CopyIntoWriter.java x: 4 # contributors y: 128 lines of code src/main/java/org/apache/doris/kafka/connector/converter/RecordDescriptor.java x: 2 # contributors y: 169 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/util/GeoUtils.java x: 2 # contributors y: 38 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisSinkService.java x: 3 # contributors y: 15 lines of code src/main/java/org/apache/doris/kafka/connector/writer/LoadStatus.java x: 3 # contributors y: 5 lines of code src/main/java/org/apache/doris/kafka/connector/writer/ResponseUtil.java x: 3 # contributors y: 10 lines of code src/main/java/org/apache/doris/kafka/connector/decode/avro/DorisAvroConverter.java x: 1 # contributors y: 142 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisSystemService.java x: 2 # contributors y: 82 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ZonedTimeType.java x: 1 # contributors y: 33 lines of code src/main/java/org/apache/doris/kafka/connector/writer/LoadConstants.java x: 4 # contributors y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/writer/load/GroupCommitMode.java x: 1 # contributors y: 21 lines of code src/main/java/org/apache/doris/kafka/connector/decode/DorisConverter.java x: 1 # contributors y: 14 lines of code src/main/java/org/apache/doris/kafka/connector/decode/DorisJsonSchema.java x: 1 # contributors y: 57 lines of code src/main/java/org/apache/doris/kafka/connector/exception/DataDecodeException.java x: 1 # contributors y: 12 lines of code src/main/java/org/apache/doris/kafka/connector/utils/BackendUtils.java x: 3 # contributors y: 47 lines of code src/main/java/org/apache/doris/kafka/connector/utils/FileNameUtils.java x: 3 # contributors y: 53 lines of code src/main/java/org/apache/doris/kafka/connector/converter/ConverterMode.java x: 1 # contributors y: 18 lines of code src/main/java/org/apache/doris/kafka/connector/writer/DeliveryGuarantee.java x: 3 # contributors y: 18 lines of code src/main/java/org/apache/doris/kafka/connector/converter/RecordTypeRegister.java x: 2 # contributors y: 92 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractGeometryType.java x: 1 # contributors y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/Type.java x: 2 # contributors y: 13 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ArrayType.java x: 1 # contributors y: 77 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/GeographyType.java x: 1 # contributors y: 10 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/GeometryType.java x: 1 # contributors y: 22 lines of code src/main/java/org/apache/doris/kafka/connector/utils/HttpPutBuilder.java x: 3 # contributors y: 89 lines of code src/main/java/org/apache/doris/kafka/connector/converter/schema/SchemaChangeManager.java x: 2 # contributors y: 149 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractType.java x: 1 # contributors y: 37 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectDateType.java x: 1 # contributors y: 25 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectTimeType.java x: 1 # contributors y: 31 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/util/SchemaUtils.java x: 1 # contributors y: 29 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractTimeType.java x: 1 # contributors y: 20 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectBytesType.java x: 1 # contributors y: 40 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectStringType.java x: 1 # contributors y: 24 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/VariableScaleDecimalType.java x: 1 # contributors y: 39 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/doris/DorisTypeProperties.java x: 1 # contributors y: 7 lines of code src/main/java/org/apache/doris/kafka/connector/model/TableDescriptor.java x: 1 # contributors y: 64 lines of code src/main/java/org/apache/doris/kafka/connector/model/doris/Field.java x: 1 # contributors y: 105 lines of code src/main/java/org/apache/doris/kafka/connector/model/doris/Schema.java x: 1 # contributors y: 74 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractTemporalType.java x: 1 # contributors y: 26 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/AbstractConnectSchemaType.java x: 1 # contributors y: 3 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ZonedTimestampType.java x: 1 # contributors y: 28 lines of code src/main/java/org/apache/doris/kafka/connector/connection/ConnectionProvider.java x: 2 # contributors y: 6 lines of code src/main/java/org/apache/doris/kafka/connector/exception/ConnectedFailedException.java x: 2 # contributors y: 12 lines of code src/main/java/org/apache/doris/kafka/connector/exception/DataConverterException.java x: 2 # contributors y: 22 lines of code src/main/java/org/apache/doris/kafka/connector/metrics/MetricsUtil.java x: 2 # contributors y: 18 lines of code src/main/java/org/apache/doris/kafka/connector/model/BackendV2.java x: 2 # contributors y: 51 lines of code src/main/java/org/apache/doris/kafka/connector/model/KafkaRespContent.java x: 2 # contributors y: 31 lines of code src/main/java/org/apache/doris/kafka/connector/model/LoadOperation.java x: 2 # contributors y: 8 lines of code src/main/java/org/apache/doris/kafka/connector/utils/HttpPostBuilder.java x: 2 # contributors y: 44 lines of code src/main/java/org/apache/doris/kafka/connector/utils/HttpUtils.java x: 2 # contributors y: 19 lines of code src/main/java/org/apache/doris/kafka/connector/writer/CopySQLBuilder.java x: 2 # contributors y: 45 lines of code src/main/java/org/apache/doris/kafka/connector/writer/PartitionBuffer.java x: 2 # contributors y: 55 lines of code src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommittable.java x: 2 # contributors y: 78 lines of code
293.0
lines of code
  min: 3.0
  average: 53.07
  25th percentile: 15.0
  median: 23.0
  75th percentile: 58.75
  max: 293.0
0 6.0
# contributors
min: 1.0 | average: 2.04 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 3.0 | max: 6.0