apache / doris-kafka-connector
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 114 files with 6,050 lines of code in files.
    • 90 files that are 366+ days old (4,903 lines of code)
    • 23 files that are 181-365 days old (1,132 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 1 files that are 1-30 days old (15 lines of code)
81% | 18% | 0% | 0% | <1%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 114 files with 6,050 lines of code in files.
    • 28 files have been last changed 366+ days ago (666 lines of code)
    • 61 files have been last changed 181-365 days ago (2,076 lines of code)
    • 13 files have been last changed 91-180 days ago (1,491 lines of code)
    • 0 files have been last changed 31-90 days ago (0 lines of code)
    • 12 files have been last changed 1-30 days ago (1,817 lines of code)
11% | 34% | 24% | 0% | 30%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, sql, json, yaml, properties, sh, md, avsc, txt, gitignore, xml
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java81% | 18% | 0% | 0% | <1%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java11% | 34% | 24% | 0% | 30%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
src81% | 18% | 0% | 0% | <1%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
src11% | 34% | 24% | 0% | 30%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
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...
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
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...
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...
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...
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...
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
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...
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...
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
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...
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....
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...
DorisCommittable.java
in src/main/java/org/apache/doris/kafka/connector/writer/commit
78 11 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
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
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...
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...
PartitionBuffer.java
in src/main/java/org/apache/doris/kafka/connector/writer
55 11 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
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...
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....
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
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....
CopySQLBuilder.java
in src/main/java/org/apache/doris/kafka/connector/writer
45 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
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...
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...
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
RecordBuffer.java
in src/main/java/org/apache/doris/kafka/connector/writer
30 3 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
StreamLoadException.java
in src/main/java/org/apache/doris/kafka/connector/exception
22 5 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
DataConverterException.java
in src/main/java/org/apache/doris/kafka/connector/exception
22 5 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
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
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
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....
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....
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....
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
UploadException.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
DataLoad.java
in src/main/java/org/apache/doris/kafka/connector/writer/load
13 - 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
ConnectedFailedException.java
in src/main/java/org/apache/doris/kafka/connector/exception
12 3 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
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
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....
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...
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...
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
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
ConnectedFailedException.java
in src/main/java/org/apache/doris/kafka/connector/exception
12 3 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
DataLoad.java
in src/main/java/org/apache/doris/kafka/connector/writer/load
13 - 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
UploadException.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
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
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
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
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
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
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
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
DataConverterException.java
in src/main/java/org/apache/doris/kafka/connector/exception
22 5 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
StreamLoadException.java
in src/main/java/org/apache/doris/kafka/connector/exception
22 5 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
RecordBuffer.java
in src/main/java/org/apache/doris/kafka/connector/writer
30 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
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
CopySQLBuilder.java
in src/main/java/org/apache/doris/kafka/connector/writer
45 2 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
PartitionBuffer.java
in src/main/java/org/apache/doris/kafka/connector/writer
55 11 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
DorisCommittable.java
in src/main/java/org/apache/doris/kafka/connector/writer/commit
78 11 2024-03-04 2024-03-04 1 2 morningman@163.com 1747644936@qq.com
AbstractConnectSchemaType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
3 - 2024-04-15 2024-04-15 1 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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
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....
DorisTypeProperties.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/doris
7 - 2024-05-16 2024-05-16 1 1 46414265+dongliang-0@users.... 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....
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....
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....
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....
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....
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....
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....
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....
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....
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
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...
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...
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....
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....
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....
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....
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...
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....
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...
GeographyType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
10 - 2024-06-06 2024-06-06 1 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...
AbstractGeometryType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type
9 1 2024-06-06 2024-06-06 1 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...
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....
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....
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...
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....
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....
DorisTypeProperties.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/doris
7 - 2024-05-16 2024-05-16 1 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....
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....
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....
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....
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....
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...
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....
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....
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....
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....
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....
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....
Most Recently Changed Files (Top 50)
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...
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...
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...
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...
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
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...
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...
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
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
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
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...
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...
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...
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...
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...
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...
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...
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...
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...
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...
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....
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....
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....
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....
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....
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....
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....
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....
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...
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...
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....
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....
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....
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....
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....
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....
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....
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....
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....
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...
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....
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...
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...
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...
GeographyType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
10 - 2024-06-06 2024-06-06 1 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...
AbstractGeometryType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type
9 1 2024-06-06 2024-06-06 1 1 31833513+vinlee19@users.nor... 31833513+vinlee19@users.nor...