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 125 files with 10,289 lines of code in files.
    • 75 files that are 366+ days old (5,301 lines of code)
    • 23 files that are 181-365 days old (2,647 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 14 files that are 31-90 days old (1,215 lines of code)
    • 13 files that are 1-30 days old (1,126 lines of code)
51% | 25% | 0% | 11% | 10%
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 125 files with 10,289 lines of code in files.
    • 48 files have been last changed 366+ days ago (1,890 lines of code)
    • 18 files have been last changed 181-365 days ago (1,081 lines of code)
    • 8 files have been last changed 91-180 days ago (1,462 lines of code)
    • 17 files have been last changed 31-90 days ago (1,567 lines of code)
    • 34 files have been last changed 1-30 days ago (4,289 lines of code)
18% | 10% | 14% | 15% | 41%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, yml, md, txt, sh, properties, yaml, tpl, gitignore, xml, json
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java51% | 25% | 0% | 11% | 10%
tpl100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java18% | 10% | 14% | 15% | 41%
tpl0% | 0% | 0% | 100% | 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-connector51% | 25% | 0% | 11% | 10%
ROOT100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
flink-doris-connector18% | 10% | 14% | 15% | 41%
ROOT0% | 0% | 0% | 100% | 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
491 20 2022-02-11 2023-04-19 12 8 chenmingyu@baidu.com adamlee489@gmail.com
RowBatch.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/serialization
339 14 2022-02-11 2023-08-08 10 7 chenmingyu@baidu.com zhongyk10@gmail.com
DorisDynamicTableFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
215 8 2022-02-11 2023-08-07 11 4 chenmingyu@baidu.com 676366545@qq.com
DorisExecutionOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
197 34 2022-02-11 2023-08-07 8 4 chenmingyu@baidu.com 676366545@qq.com
BackendClient.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/backend
167 6 2022-02-11 2023-05-18 4 4 chenmingyu@baidu.com 46414265+dongliang-0@users....
DorisReadOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
146 30 2022-02-11 2022-04-25 3 2 chenmingyu@baidu.com 676366545@qq.com
DorisRowDataInputFormat.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
142 21 2022-02-11 2022-07-21 5 4 chenmingyu@baidu.com 676366545@qq.com
DorisDynamicTableSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
126 7 2022-02-11 2023-01-17 6 3 chenmingyu@baidu.com 676366545@qq.com
PartitionDefinition.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
105 10 2022-02-11 2022-04-21 2 2 chenmingyu@baidu.com 676366545@qq.com
DorisDynamicTableSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
96 5 2022-02-11 2023-08-07 8 6 chenmingyu@baidu.com 676366545@qq.com
Field.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
85 17 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
DorisSourceFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/datastream
79 6 2022-02-11 2022-09-14 4 3 chenmingyu@baidu.com 843520313@qq.com
RespContent.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
71 7 2022-02-11 2022-03-08 2 2 chenmingyu@baidu.com 44109015+madongz@users.nore...
Schema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
71 15 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
DorisOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
58 11 2022-02-11 2023-01-17 3 2 chenmingyu@baidu.com 676366545@qq.com
DorisConnectionOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
56 11 2022-02-11 2023-01-17 2 2 chenmingyu@baidu.com 676366545@qq.com
Tablet.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
51 10 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
BackendV2.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
44 9 2022-02-11 2023-02-01 2 2 chenmingyu@baidu.com 676366545@qq.com
QueryPlan.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
43 8 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
Routing.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/serialization
41 5 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
DorisStreamOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
40 4 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
BackendRow.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
39 7 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
ConfigurationOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
35 - 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
IOUtils.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/util
29 2 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
StreamLoadException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
20 5 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
DorisException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
20 5 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
DorisTableInputSplit.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
16 2 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
Backend.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
16 2 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
SimpleListDeserializationSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization
16 1 2022-02-11 2022-04-21 2 2 chenmingyu@baidu.com 676366545@qq.com
SchemaUtils.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
12 1 2022-02-11 2023-05-18 2 2 chenmingyu@baidu.com 46414265+dongliang-0@users....
ErrorMessages.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/util
9 - 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
IllegalArgumentException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
9 2 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
ConnectedFailedException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
9 2 2022-02-11 2022-07-21 2 2 chenmingyu@baidu.com 676366545@qq.com
DorisInternalException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
8 1 2022-02-11 2023-05-18 3 3 chenmingyu@baidu.com 46414265+dongliang-0@users....
DorisDeserializationSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization
8 - 2022-02-11 2022-04-21 3 3 chenmingyu@baidu.com 676366545@qq.com
ShouldNeverHappenException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
3 - 2022-02-11 2022-07-21 2 2 chenmingyu@baidu.com 676366545@qq.com
2 - 2022-02-11 2023-05-18 2 2 chenmingyu@baidu.com 46414265+dongliang-0@users....
DorisStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
238 13 2022-03-08 2023-04-10 10 4 44109015+madongz@users.nore... 676366545@qq.com
DorisWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
175 10 2022-03-08 2023-08-07 9 3 44109015+madongz@users.nore... 676366545@qq.com
RowDataSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
121 11 2022-03-08 2023-03-14 4 3 44109015+madongz@users.nore... 676366545@qq.com
RecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
104 8 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
DorisCommitter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer
98 5 2022-03-08 2023-04-10 5 4 44109015+madongz@users.nore... 676366545@qq.com
DorisSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
93 8 2022-03-08 2023-03-10 3 2 44109015+madongz@users.nore... 676366545@qq.com
HttpPutBuilder.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
84 14 2022-03-08 2022-11-18 2 2 44109015+madongz@users.nore... 676366545@qq.com
DorisCommittable.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
46 7 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
EscapeHandler.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
39 3 2022-03-08 2023-03-10 2 2 44109015+madongz@users.nore... 676366545@qq.com
DorisCommittableSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
34 2 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
RecordStream.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
34 6 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
DorisWriterState.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
32 5 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
DorisWriterStateSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
30 2 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
IllegalArgumentException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
9 2 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
ErrorMessages.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/util
9 - 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
Backend.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
16 2 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
DorisTableInputSplit.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
16 2 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
DorisException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
20 5 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
StreamLoadException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
20 5 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
IOUtils.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/util
29 2 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
ConfigurationOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
35 - 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
BackendRow.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
39 7 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
DorisStreamOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
40 4 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
Routing.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/serialization
41 5 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
QueryPlan.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
43 8 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
Tablet.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
51 10 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
Schema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
71 15 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
Field.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
85 17 2022-02-11 2022-02-11 1 1 chenmingyu@baidu.com chenmingyu@baidu.com
DorisRecordSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
6 - 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
SimpleStringSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
9 - 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
LoadConstants.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
13 - 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
ResponseUtil.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
13 1 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
HttpUtil.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
18 2 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
DorisRuntimeException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
20 5 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
DorisWriterStateSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
30 2 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
DorisWriterState.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
32 5 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
RecordStream.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
34 6 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
DorisCommittableSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
34 2 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
DorisCommittable.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
46 7 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
RespContent.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
71 7 2022-02-11 2022-03-08 2 2 chenmingyu@baidu.com 44109015+madongz@users.nore...
RecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
104 8 2022-03-08 2022-03-08 1 1 44109015+madongz@users.nore... 44109015+madongz@users.nore...
DorisDeserializationSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization
8 - 2022-02-11 2022-04-21 3 3 chenmingyu@baidu.com 676366545@qq.com
DorisSourceSplitState.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/split
10 2 2022-04-21 2022-04-21 1 1 676366545@qq.com 676366545@qq.com
DorisSplitAssigner.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners
11 - 2022-04-21 2022-04-21 1 1 676366545@qq.com 676366545@qq.com
PendingSplitsCheckpoint.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator
15 2 2022-04-21 2022-04-21 1 1 676366545@qq.com 676366545@qq.com
SimpleListDeserializationSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization
16 1 2022-02-11 2022-04-21 2 2 chenmingyu@baidu.com 676366545@qq.com
SimpleSplitAssigner.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners
30 5 2022-04-21 2022-04-21 1 1 676366545@qq.com 676366545@qq.com
DorisRecordEmitter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
31 4 2022-04-21 2022-04-21 1 1 676366545@qq.com 676366545@qq.com
DorisSourceBuilder.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source
36 6 2022-04-21 2022-04-21 1 1 676366545@qq.com 676366545@qq.com
DorisSourceSplit.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/split
39 5 2022-04-21 2022-04-21 1 1 676366545@qq.com 676366545@qq.com
DorisSourceReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
40 5 2022-04-21 2022-04-21 1 1 676366545@qq.com 676366545@qq.com
DorisSourceEnumerator.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator
57 7 2022-04-21 2022-04-21 1 1 676366545@qq.com 676366545@qq.com
PendingSplitsCheckpointSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator
78 4 2022-04-21 2022-04-21 1 1 676366545@qq.com 676366545@qq.com
DorisSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source
88 8 2022-04-21 2022-04-21 1 1 676366545@qq.com 676366545@qq.com
PartitionDefinition.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
105 10 2022-02-11 2022-04-21 2 2 chenmingyu@baidu.com 676366545@qq.com
DorisReadOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
146 30 2022-02-11 2022-04-25 3 2 chenmingyu@baidu.com 676366545@qq.com
RowDataDeserializationSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization
23 3 2022-04-21 2022-06-12 2 2 676366545@qq.com rancho_zhanggj@163.com
ShouldNeverHappenException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
3 - 2022-02-11 2022-07-21 2 2 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 2022-07-21 2 2 chenmingyu@baidu.com 676366545@qq.com
DorisSplitRecords.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/split
49 6 2022-04-21 2022-07-21 2 1 676366545@qq.com 676366545@qq.com
DorisRowDataInputFormat.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
142 21 2022-02-11 2022-07-21 5 4 chenmingyu@baidu.com 676366545@qq.com
DorisSourceSplitReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
66 7 2022-04-21 2022-09-06 3 1 676366545@qq.com 676366545@qq.com
DorisSourceFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/datastream
79 6 2022-02-11 2022-09-14 4 3 chenmingyu@baidu.com 843520313@qq.com
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
DorisBatchStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
236 12 2023-08-07 2023-08-07 1 1 676366545@qq.com 676366545@qq.com
BatchRecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
86 14 2023-08-07 2023-08-07 1 1 676366545@qq.com 676366545@qq.com
DorisBatchWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
84 7 2023-08-07 2023-08-07 1 1 676366545@qq.com 676366545@qq.com
DorisBatchSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
64 3 2023-08-07 2023-08-07 1 1 676366545@qq.com 676366545@qq.com
BackendUtil.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
44 3 2023-08-07 2023-08-07 1 1 676366545@qq.com 676366545@qq.com
DorisBatchLoadException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
20 5 2023-08-07 2023-08-07 1 1 676366545@qq.com 676366545@qq.com
SchemaChangeHelper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
78 6 2023-08-03 2023-08-03 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
DorisJsonDebeziumDeserializationSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization
153 4 2023-07-21 2023-07-21 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
OracleDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
154 4 2023-07-19 2023-07-21 2 1 676366545@qq.com 676366545@qq.com
OracleDateConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
103 5 2023-07-19 2023-07-19 1 1 676366545@qq.com 676366545@qq.com
OracleType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
81 1 2023-07-19 2023-07-19 1 1 676366545@qq.com 676366545@qq.com
OracleSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
12 2 2023-07-19 2023-07-19 1 1 676366545@qq.com 676366545@qq.com
MysqlSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
11 2 2023-07-19 2023-07-19 1 1 676366545@qq.com 676366545@qq.com
DorisSystemException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
20 5 2023-06-26 2023-06-26 1 1 676366545@qq.com 676366545@qq.com
DorisSystem.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
191 17 2023-06-05 2023-08-03 5 1 676366545@qq.com 676366545@qq.com
DatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
184 6 2023-06-05 2023-08-07 6 3 676366545@qq.com 676366545@qq.com
MysqlDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
176 5 2023-06-05 2023-07-21 4 2 676366545@qq.com 46414265+dongliang-0@users....
MysqlType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
148 1 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
DateToStringConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
116 8 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
SourceSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
96 11 2023-06-05 2023-08-03 4 1 676366545@qq.com 676366545@qq.com
CdcTools.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
87 5 2023-06-05 2023-08-03 4 2 676366545@qq.com 46414265+dongliang-0@users....
TableSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
63 16 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
FieldSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
44 11 2023-06-05 2023-08-03 2 2 676366545@qq.com 46414265+dongliang-0@users....
ParsingProcessFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
40 6 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
DorisType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
24 - 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
CreateTableException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
20 5 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
DataModel.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
6 - 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
ExecutionPool.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
171 9 2023-01-17 2023-07-17 2 1 676366545@qq.com 676366545@qq.com
Worker.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
170 7 2023-01-17 2023-07-17 2 1 676366545@qq.com 676366545@qq.com
RecordKey.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
109 6 2023-01-17 2023-01-17 1 1 676366545@qq.com 676366545@qq.com
DorisJdbcLookupReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
104 7 2023-01-17 2023-07-17 2 1 676366545@qq.com 676366545@qq.com
DorisRowDataAsyncLookupFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
104 4 2023-01-17 2023-07-17 3 1 676366545@qq.com 676366545@qq.com
DorisRowDataJdbcLookupFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
89 5 2023-01-17 2023-07-17 2 1 676366545@qq.com 676366545@qq.com
LookupSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
58 8 2023-01-17 2023-01-17 1 1 676366545@qq.com 676366545@qq.com
SimpleJdbcConnectionProvider.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/connection
48 3 2023-01-17 2023-07-17 2 1 676366545@qq.com 676366545@qq.com
Record.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
46 6 2023-01-17 2023-01-17 1 1 676366545@qq.com 676366545@qq.com
GetAction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
19 4 2023-01-17 2023-01-17 1 1 676366545@qq.com 676366545@qq.com
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
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
JdbcConnectionProvider.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/connection
6 - 2023-01-17 2023-01-17 1 1 676366545@qq.com 676366545@qq.com
JsonDebeziumSchemaSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
450 29 2022-11-18 2023-08-07 9 3 676366545@qq.com 676366545@qq.com
HttpGetWithEntity.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
14 2 2022-11-18 2022-11-18 1 1 676366545@qq.com 676366545@qq.com
RowSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
67 8 2022-10-10 2022-10-10 1 1 109070189+dinggege1024@user... 109070189+dinggege1024@user...
DorisRowDataLookupFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
125 5 2022-09-15 2022-09-15 1 1 676366545@qq.com 676366545@qq.com
DorisLookupOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
98 17 2022-09-15 2023-01-17 2 1 676366545@qq.com 676366545@qq.com
DorisCatalog.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
446 44 2022-09-06 2023-06-26 4 2 676366545@qq.com 676366545@qq.com
DorisConfigOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
201 1 2022-09-06 2023-08-07 6 2 676366545@qq.com 676366545@qq.com
DorisTypeMapper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
173 19 2022-09-06 2023-06-26 4 2 676366545@qq.com 676366545@qq.com
DorisCatalogFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
100 2 2022-09-06 2023-06-26 3 2 676366545@qq.com 676366545@qq.com
DorisCatalogOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
20 1 2022-09-06 2023-06-26 2 1 676366545@qq.com 676366545@qq.com
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)
# contributorsfirst
contributor
latest
contributor
RowBatch.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/serialization
339 14 2022-02-11 2023-08-08 10 7 chenmingyu@baidu.com zhongyk10@gmail.com
JsonDebeziumSchemaSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
450 29 2022-11-18 2023-08-07 9 3 676366545@qq.com 676366545@qq.com
DorisBatchStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
236 12 2023-08-07 2023-08-07 1 1 676366545@qq.com 676366545@qq.com
DorisDynamicTableFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
215 8 2022-02-11 2023-08-07 11 4 chenmingyu@baidu.com 676366545@qq.com
DorisConfigOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
201 1 2022-09-06 2023-08-07 6 2 676366545@qq.com 676366545@qq.com
DorisExecutionOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
197 34 2022-02-11 2023-08-07 8 4 chenmingyu@baidu.com 676366545@qq.com
DatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
184 6 2023-06-05 2023-08-07 6 3 676366545@qq.com 676366545@qq.com
DorisWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
175 10 2022-03-08 2023-08-07 9 3 44109015+madongz@users.nore... 676366545@qq.com
DorisDynamicTableSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
96 5 2022-02-11 2023-08-07 8 6 chenmingyu@baidu.com 676366545@qq.com
BatchRecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
86 14 2023-08-07 2023-08-07 1 1 676366545@qq.com 676366545@qq.com
DorisBatchWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
84 7 2023-08-07 2023-08-07 1 1 676366545@qq.com 676366545@qq.com
DorisBatchSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
64 3 2023-08-07 2023-08-07 1 1 676366545@qq.com 676366545@qq.com
BackendUtil.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
44 3 2023-08-07 2023-08-07 1 1 676366545@qq.com 676366545@qq.com
DorisBatchLoadException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
20 5 2023-08-07 2023-08-07 1 1 676366545@qq.com 676366545@qq.com
LabelGenerator.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
16 3 2022-06-30 2023-08-07 3 2 44109015+madongz@users.nore... 676366545@qq.com
DorisSystem.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
191 17 2023-06-05 2023-08-03 5 1 676366545@qq.com 676366545@qq.com
SourceSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
96 11 2023-06-05 2023-08-03 4 1 676366545@qq.com 676366545@qq.com
CdcTools.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
87 5 2023-06-05 2023-08-03 4 2 676366545@qq.com 46414265+dongliang-0@users....
SchemaChangeHelper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
78 6 2023-08-03 2023-08-03 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
FieldSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
44 11 2023-06-05 2023-08-03 2 2 676366545@qq.com 46414265+dongliang-0@users....
MysqlDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
176 5 2023-06-05 2023-07-21 4 2 676366545@qq.com 46414265+dongliang-0@users....
OracleDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
154 4 2023-07-19 2023-07-21 2 1 676366545@qq.com 676366545@qq.com
DorisJsonDebeziumDeserializationSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization
153 4 2023-07-21 2023-07-21 1 1 46414265+dongliang-0@users.... 46414265+dongliang-0@users....
OracleDateConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
103 5 2023-07-19 2023-07-19 1 1 676366545@qq.com 676366545@qq.com
OracleType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
81 1 2023-07-19 2023-07-19 1 1 676366545@qq.com 676366545@qq.com
OracleSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
12 2 2023-07-19 2023-07-19 1 1 676366545@qq.com 676366545@qq.com
MysqlSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
11 2 2023-07-19 2023-07-19 1 1 676366545@qq.com 676366545@qq.com
ExecutionPool.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
171 9 2023-01-17 2023-07-17 2 1 676366545@qq.com 676366545@qq.com
Worker.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
170 7 2023-01-17 2023-07-17 2 1 676366545@qq.com 676366545@qq.com
DorisJdbcLookupReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
104 7 2023-01-17 2023-07-17 2 1 676366545@qq.com 676366545@qq.com
DorisRowDataAsyncLookupFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
104 4 2023-01-17 2023-07-17 3 1 676366545@qq.com 676366545@qq.com
DorisRowDataJdbcLookupFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
89 5 2023-01-17 2023-07-17 2 1 676366545@qq.com 676366545@qq.com
SimpleJdbcConnectionProvider.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/connection
48 3 2023-01-17 2023-07-17 2 1 676366545@qq.com 676366545@qq.com
DorisLookupReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
10 - 2023-01-17 2023-07-17 2 1 676366545@qq.com 676366545@qq.com
DorisCatalog.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
446 44 2022-09-06 2023-06-26 4 2 676366545@qq.com 676366545@qq.com
DorisTypeMapper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
173 19 2022-09-06 2023-06-26 4 2 676366545@qq.com 676366545@qq.com
DorisCatalogFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
100 2 2022-09-06 2023-06-26 3 2 676366545@qq.com 676366545@qq.com
DorisCatalogOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
20 1 2022-09-06 2023-06-26 2 1 676366545@qq.com 676366545@qq.com
DorisSystemException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
20 5 2023-06-26 2023-06-26 1 1 676366545@qq.com 676366545@qq.com
MysqlType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
148 1 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
DateToStringConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
116 8 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
TableSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
63 16 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
ParsingProcessFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
40 6 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
DorisType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
24 - 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
CreateTableException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
20 5 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
DataModel.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
6 - 2023-06-05 2023-06-05 1 1 676366545@qq.com 676366545@qq.com
DorisValueReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
202 9 2022-07-21 2023-05-18 3 2 676366545@qq.com 46414265+dongliang-0@users....
BackendClient.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/backend
167 6 2022-02-11 2023-05-18 4 4 chenmingyu@baidu.com 46414265+dongliang-0@users....
SchemaUtils.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
12 1 2022-02-11 2023-05-18 2 2 chenmingyu@baidu.com 46414265+dongliang-0@users....
DorisInternalException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
8 1 2022-02-11 2023-05-18 3 3 chenmingyu@baidu.com 46414265+dongliang-0@users....