apache / doris-flink-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 196 files with 20,434 lines of code in files.
    • 166 files that are 366+ days old (17,393 lines of code)
    • 27 files that are 181-365 days old (2,911 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 3 files that are 31-90 days old (130 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
85% | 14% | 0% | <1% | 0%
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 196 files with 20,434 lines of code in files.
    • 61 files have been last changed 366+ days ago (3,013 lines of code)
    • 72 files have been last changed 181-365 days ago (7,049 lines of code)
    • 22 files have been last changed 91-180 days ago (2,613 lines of code)
    • 40 files have been last changed 31-90 days ago (7,654 lines of code)
    • 1 files have been last changed 1-30 days ago (105 lines of code)
14% | 34% | 12% | 37% | <1%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, yaml, txt, sql, sh, md, xml, properties, gitignore, tpl
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java85% | 14% | 0% | <1% | 0%
xml100% | 0% | 0% | 0% | 0%
tpl100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java14% | 34% | 12% | 37% | <1%
xml100% | 0% | 0% | 0% | 0%
tpl100% | 0% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
flink-doris-connector85% | 14% | 0% | <1% | 0%
tools100% | 0% | 0% | 0% | 0%
ROOT100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
flink-doris-connector14% | 34% | 12% | 37% | <1%
tools100% | 0% | 0% | 0% | 0%
ROOT100% | 0% | 0% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
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
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
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
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
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
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
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
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
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....
PartitionDefinition.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
132 12 2022-02-11 2024-12-26 5 3 chenmingyu@baidu.com 676366545@qq.com
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
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
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
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
Field.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
87 15 2022-02-11 2025-01-23 4 3 chenmingyu@baidu.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
Schema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
68 13 2022-02-11 2025-01-23 4 3 chenmingyu@baidu.com 676366545@qq.com
BackendV2.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
52 10 2022-02-11 2025-01-23 5 3 chenmingyu@baidu.com 676366545@qq.com
SchemaUtils.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
45 2 2022-02-11 2024-08-12 4 3 chenmingyu@baidu.com xyws5566@qq.com
Routing.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/serialization
38 5 2022-02-11 2023-12-14 2 2 chenmingyu@baidu.com 46414265+dongliang-0@users....
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
Tablet.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
34 8 2022-02-11 2025-01-23 4 3 chenmingyu@baidu.com 676366545@qq.com
QueryPlan.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
31 6 2022-02-11 2025-01-23 4 3 chenmingyu@baidu.com 676366545@qq.com
DorisTableInputSplit.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
26 3 2022-02-11 2024-10-25 3 3 chenmingyu@baidu.com 676366545@qq.com
DorisException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
22 5 2022-02-11 2023-12-14 2 2 chenmingyu@baidu.com 46414265+dongliang-0@users....
SimpleListDeserializationSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization
17 1 2022-02-11 2024-06-05 4 3 chenmingyu@baidu.com 676366545@qq.com
DorisInternalException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
14 1 2022-02-11 2023-12-14 4 3 chenmingyu@baidu.com 46414265+dongliang-0@users....
ErrorMessages.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/util
13 - 2022-02-11 2023-12-14 2 2 chenmingyu@baidu.com 46414265+dongliang-0@users....
IllegalArgumentException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
12 3 2022-02-11 2024-09-20 2 2 chenmingyu@baidu.com 37775475+qg-lin@users.norep...
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
StreamLoadException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
9 2 2022-02-11 2024-05-30 3 3 chenmingyu@baidu.com 676366545@qq.com
ConnectedFailedException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
9 2 2022-02-11 2023-10-08 3 2 chenmingyu@baidu.com 676366545@qq.com
2 - 2022-02-11 2023-05-18 2 2 chenmingyu@baidu.com 46414265+dongliang-0@users....
ShouldNeverHappenException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
2 - 2022-02-11 2023-12-14 3 3 chenmingyu@baidu.com 46414265+dongliang-0@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
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
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
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
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
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
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
DorisWriterState.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
63 9 2022-03-08 2023-12-15 3 3 44109015+madongz@users.nore... 46414265+dongliang-0@users....
DorisCommittable.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
51 7 2022-03-08 2024-02-01 3 3 44109015+madongz@users.nore... 676366545@qq.com
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
DorisWriterStateSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
41 2 2022-03-08 2023-12-15 3 3 44109015+madongz@users.nore... 46414265+dongliang-0@users....
EscapeHandler.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
39 3 2022-03-08 2023-12-15 3 3 44109015+madongz@users.nore... 46414265+dongliang-0@users....
DorisCommittableSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
34 2 2022-03-08 2023-12-15 2 2 44109015+madongz@users.nore... 46414265+dongliang-0@users....
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
ResponseUtil.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
23 3 2022-03-08 2024-04-15 5 3 44109015+madongz@users.nore... 676366545@qq.com
DorisRuntimeException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
22 5 2022-03-08 2023-12-14 2 2 44109015+madongz@users.nore... 46414265+dongliang-0@users....
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
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
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
2 - 2022-02-11 2023-05-18 2 2 chenmingyu@baidu.com 46414265+dongliang-0@users....
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
ConnectedFailedException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
9 2 2022-02-11 2023-10-08 3 2 chenmingyu@baidu.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
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
ShouldNeverHappenException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
2 - 2022-02-11 2023-12-14 3 3 chenmingyu@baidu.com 46414265+dongliang-0@users....
DorisSourceSplitState.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/split
10 2 2022-04-21 2023-12-14 2 2 676366545@qq.com 46414265+dongliang-0@users....
DorisSplitAssigner.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners
11 - 2022-04-21 2023-12-14 2 2 676366545@qq.com 46414265+dongliang-0@users....
ErrorMessages.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/util
13 - 2022-02-11 2023-12-14 2 2 chenmingyu@baidu.com 46414265+dongliang-0@users....
PendingSplitsCheckpoint.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator
14 2 2022-04-21 2023-12-14 2 2 676366545@qq.com 46414265+dongliang-0@users....
DorisInternalException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
14 1 2022-02-11 2023-12-14 4 3 chenmingyu@baidu.com 46414265+dongliang-0@users....
DorisRuntimeException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
22 5 2022-03-08 2023-12-14 2 2 44109015+madongz@users.nore... 46414265+dongliang-0@users....
DorisException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
22 5 2022-02-11 2023-12-14 2 2 chenmingyu@baidu.com 46414265+dongliang-0@users....
DorisSchemaChangeException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
22 5 2023-11-30 2023-12-14 2 2 676366545@qq.com 46414265+dongliang-0@users....
DorisRecordEmitter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
31 4 2022-04-21 2023-12-14 2 2 676366545@qq.com 46414265+dongliang-0@users....
Routing.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/serialization
38 5 2022-02-11 2023-12-14 2 2 chenmingyu@baidu.com 46414265+dongliang-0@users....
PendingSplitsCheckpointSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator
80 4 2022-04-21 2023-12-14 2 2 676366545@qq.com 46414265+dongliang-0@users....
JdbcConnectionProvider.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/connection
6 - 2023-01-17 2023-12-15 2 2 676366545@qq.com 46414265+dongliang-0@users....
LoadStatus.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
7 - 2022-03-08 2023-12-15 3 2 44109015+madongz@users.nore... 46414265+dongliang-0@users....
suppressions.xml
in tools/maven
7 - 2023-12-14 2023-12-15 2 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
HttpGetWithEntity.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
14 2 2022-11-18 2023-12-15 2 2 676366545@qq.com 46414265+dongliang-0@users....
DorisCatalogOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
23 1 2022-09-06 2023-12-15 3 2 676366545@qq.com 46414265+dongliang-0@users....
DorisCommittableSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
34 2 2022-03-08 2023-12-15 2 2 44109015+madongz@users.nore... 46414265+dongliang-0@users....
EscapeHandler.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
39 3 2022-03-08 2023-12-15 3 3 44109015+madongz@users.nore... 46414265+dongliang-0@users....
DorisWriterStateSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
41 2 2022-03-08 2023-12-15 3 3 44109015+madongz@users.nore... 46414265+dongliang-0@users....
Record.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
43 6 2023-01-17 2023-12-15 2 2 676366545@qq.com 46414265+dongliang-0@users....
DorisWriterState.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
63 9 2022-03-08 2023-12-15 3 3 44109015+madongz@users.nore... 46414265+dongliang-0@users....
LookupSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
69 8 2023-01-17 2023-12-15 2 2 676366545@qq.com 46414265+dongliang-0@users....
CacheRecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
87 7 2023-09-26 2023-12-15 2 2 82132356+gogowen@users.nore... 46414265+dongliang-0@users....
DorisJdbcLookupReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
106 7 2023-01-17 2023-12-15 3 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....
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....
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....
DorisRecord.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer
55 11 2023-11-29 2023-12-27 3 3 676366545@qq.com wuwenchihdu@hotmail.com
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
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....
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...
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
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
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
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
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
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
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
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
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
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
DorisCommittable.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
51 7 2022-03-08 2024-02-01 3 3 44109015+madongz@users.nore... 676366545@qq.com
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
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....
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....
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
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
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
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
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
ValueReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
35 1 2024-08-12 2025-03-13 4 2 xyws5566@qq.com 676366545@qq.com
DorisTableConfig.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
78 6 2024-07-30 2024-12-06 4 2 46414265+dongliang-0@users.... 676366545@qq.com
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...
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...
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...
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...
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
DatabaseSyncConfig.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
66 - 2024-07-25 2024-09-11 3 3 46414265+dongliang-0@users.... 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
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
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....
MongoJsonDebeziumSchemaChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer
209 13 2024-05-30 2025-03-27 4 3 676366545@qq.com 76644839+kwonder0926@users....
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....
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
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....
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....
MongoDBSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
130 10 2024-05-08 2025-03-27 5 3 bingquan_zhao@icloud.com 76644839+kwonder0926@users....
MongoDBType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
105 5 2024-05-08 2025-04-21 4 3 bingquan_zhao@icloud.com 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
MongoParsingProcessFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
23 2 2024-05-08 2025-02-26 3 2 bingquan_zhao@icloud.com 676366545@qq.com
ChangeStreamConstant.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
21 - 2024-05-08 2025-02-10 2 2 bingquan_zhao@icloud.com 781240052@qq.com
MongoDateConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
17 1 2024-05-08 2024-07-25 2 2 bingquan_zhao@icloud.com 46414265+dongliang-0@users....
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...
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
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...
JdbcSourceSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
93 4 2024-02-29 2024-12-06 5 3 bingquan_zhao@icloud.com 676366545@qq.com
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
CdcSchemaChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
9 - 2024-02-29 2025-01-10 2 2 bingquan_zhao@icloud.com 676366545@qq.com
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
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
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
JsonDebeziumChangeUtils.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
71 5 2024-02-01 2024-07-26 5 2 46414265+dongliang-0@users.... 31833513+vinlee19@users.nor...
CopySQLBuilder.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
68 3 2024-02-01 2024-08-06 3 2 676366545@qq.com 46414265+dongliang-0@users....
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
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
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
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
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
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
MongoDBType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
105 5 2024-05-08 2025-04-21 4 3 bingquan_zhao@icloud.com 76644839+kwonder0926@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...
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....
MongoJsonDebeziumSchemaChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer
209 13 2024-05-30 2025-03-27 4 3 676366545@qq.com 76644839+kwonder0926@users....
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....
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....
MongoDBSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
130 10 2024-05-08 2025-03-27 5 3 bingquan_zhao@icloud.com 76644839+kwonder0926@users....
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....
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....
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....
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
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
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
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
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
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
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
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
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
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
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
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
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
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
ValueReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
35 1 2024-08-12 2025-03-13 4 2 xyws5566@qq.com 676366545@qq.com
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
DataModel.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
7 - 2023-06-05 2025-03-12 3 2 676366545@qq.com 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
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
JsonDebeziumChangeContext.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
130 17 2024-01-03 2025-02-26 6 3 46414265+dongliang-0@users.... 676366545@qq.com
ParsingProcessFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
57 8 2023-11-29 2025-02-26 5 3 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
MongoParsingProcessFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
23 2 2024-05-08 2025-02-26 3 2 bingquan_zhao@icloud.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
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
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
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
ChangeStreamConstant.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
21 - 2024-05-08 2025-02-10 2 2 bingquan_zhao@icloud.com 781240052@qq.com
Field.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
87 15 2022-02-11 2025-01-23 4 3 chenmingyu@baidu.com 676366545@qq.com
Schema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
68 13 2022-02-11 2025-01-23 4 3 chenmingyu@baidu.com 676366545@qq.com
BackendV2.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
52 10 2022-02-11 2025-01-23 5 3 chenmingyu@baidu.com 676366545@qq.com
Tablet.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
34 8 2022-02-11 2025-01-23 4 3 chenmingyu@baidu.com 676366545@qq.com
QueryPlan.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
31 6 2022-02-11 2025-01-23 4 3 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
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
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
CdcSchemaChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
9 - 2024-02-29 2025-01-10 2 2 bingquan_zhao@icloud.com 676366545@qq.com