apache / doris-flink-connector
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 125 files with 10,289 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 12 files changed 6-20 times (3,017 lines of code)
    • 113 files changed 1-5 times (7,272 lines of code)
0% | 0% | 0% | 29% | 70%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 125 files with 10,289 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 3 files changed by 6-10 contributors (926 lines of code)
    • 40 files changed by 2-5 contributors (4,726 lines of code)
    • 82 files changed by 1 contributor (4,637 lines of code)
0% | 0% | 8% | 45% | 45%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, yml, md, txt, sh, properties, yaml, tpl, gitignore, xml, json
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 29% | 70%
tpl0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
flink-doris-connector0% | 0% | 0% | 29% | 70%
ROOT0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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
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
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
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
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
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
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
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
DorisRowConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter
 305 17 2022-04-21 2023-04-10 7 3 676366545@qq.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
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
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
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
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
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
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
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....
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
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
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....
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
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....
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
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
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....
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
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
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
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
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
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
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
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....
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
 3 - 2022-02-11 2022-07-21 2 2 chenmingyu@baidu.com 676366545@qq.com
LoadStatus.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 7 - 2022-03-08 2022-11-21 2 2 44109015+madongz@users.nore... 46414265+dongliang-0@users....
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
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
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....
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
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
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
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
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
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....
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
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
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
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...
DorisSourceSplitSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/split
 77 4 2022-04-21 2023-04-10 2 1 676366545@qq.com 676366545@qq.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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
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
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
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
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
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
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
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....
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
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
DorisRowConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter
 305 17 2022-04-21 2023-04-10 7 3 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
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
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
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
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
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
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....
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....
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
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
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
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....
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
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
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
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
2 - 2022-02-11 2023-05-18 2 2 chenmingyu@baidu.com 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....
LoadStatus.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 7 - 2022-03-08 2022-11-21 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-03-10 2 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
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
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
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...
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
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
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....
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
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
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
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
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
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
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
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
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
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
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
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
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....
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
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
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
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
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...
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
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
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
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
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
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
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
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
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
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
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
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....
DorisSourceSplitSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/split
 77 4 2022-04-21 2023-04-10 2 1 676366545@qq.com 676366545@qq.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
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...
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
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
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
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
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
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
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
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
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...
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
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
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
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
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
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
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
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
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
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
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...
Correlations

File Size vs. Number of Changes: 125 points

flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 339 lines of code y: 10 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 197 lines of code y: 8 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java x: 450 lines of code y: 9 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 201 lines of code y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java x: 215 lines of code y: 11 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java x: 96 lines of code y: 8 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 184 lines of code y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java x: 20 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java x: 44 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java x: 86 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java x: 64 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java x: 236 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java x: 84 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java x: 175 lines of code y: 9 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java x: 16 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/FieldSchema.java x: 44 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/SchemaChangeHelper.java x: 78 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java x: 87 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java x: 191 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java x: 96 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisJsonDebeziumDeserializationSchema.java x: 153 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java x: 176 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java x: 154 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java x: 11 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java x: 103 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleSchema.java x: 12 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java x: 81 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java x: 48 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisJdbcLookupReader.java x: 104 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisLookupReader.java x: 10 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java x: 171 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java x: 170 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java x: 104 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java x: 89 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java x: 446 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java x: 100 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogOptions.java x: 20 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java x: 173 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java x: 6 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisType.java x: 24 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/TableSchema.java x: 63 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DateToStringConverter.java x: 116 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java x: 148 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/ParsingProcessFunction.java x: 40 lines of code y: 1 # changes custom_env.sh.tpl x: 2 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java x: 167 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisInternalException.java x: 8 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/SchemaUtils.java x: 12 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisValueReader.java x: 202 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java x: 491 lines of code y: 12 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java x: 305 lines of code y: 7 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java x: 98 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java x: 238 lines of code y: 10 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplitSerializer.java x: 77 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RowDataSerializer.java x: 121 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisSink.java x: 93 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/EscapeHandler.java x: 39 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisConnectionOptions.java x: 56 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java x: 98 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java x: 58 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Get.java x: 19 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/LookupSchema.java x: 58 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Record.java x: 46 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java x: 109 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java x: 126 lines of code y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/LoadStatus.java x: 7 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpGetWithEntity.java x: 14 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpPutBuilder.java x: 84 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RowSerializer.java x: 67 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataLookupFunction.java x: 125 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java x: 79 lines of code y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceSplitReader.java x: 66 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ConnectedFailedException.java x: 9 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java x: 3 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSplitRecords.java x: 49 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java x: 142 lines of code y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/RowDataDeserializationSchema.java x: 23 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java x: 146 lines of code y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/SimpleListDeserializationSchema.java x: 16 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java x: 105 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSource.java x: 88 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSourceBuilder.java x: 36 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners/SimpleSplitAssigner.java x: 30 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumerator.java x: 57 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/PendingSplitsCheckpoint.java x: 15 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisRecordEmitter.java x: 31 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java x: 39 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplitState.java x: 10 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/RespContent.java x: 71 lines of code y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittableSerializer.java x: 34 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java x: 18 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/ResponseUtil.java x: 13 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java x: 32 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java x: 104 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/SimpleStringSerializer.java x: 9 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java x: 35 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Backend.java x: 16 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java x: 85 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java x: 43 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java x: 71 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java x: 51 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/Routing.java x: 41 lines of code y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/util/IOUtils.java x: 29 lines of code y: 1 # changes
12.0
# changes
  min: 1.0
  average: 2.37
  25th percentile: 1.0
  median: 1.0
  75th percentile: 3.0
  max: 12.0
0 491.0
lines of code
min: 2.0 | average: 82.31 | 25th percentile: 20.0 | median: 51.0 | 75th percentile: 104.0 | max: 491.0

Number of Contributors vs. Number of Changes: 125 points

flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 7 # contributors y: 10 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 4 # contributors y: 8 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java x: 3 # contributors y: 9 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 2 # contributors y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java x: 4 # contributors y: 11 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java x: 6 # contributors y: 8 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 3 # contributors y: 6 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java x: 1 # contributors y: 1 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java x: 2 # contributors y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/FieldSchema.java x: 2 # contributors y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java x: 2 # contributors y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java x: 1 # contributors y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java x: 1 # contributors y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java x: 1 # contributors y: 2 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java x: 1 # contributors y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java x: 4 # contributors y: 4 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisInternalException.java x: 3 # contributors y: 3 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java x: 8 # contributors y: 12 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java x: 3 # contributors y: 7 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java x: 4 # contributors y: 5 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java x: 4 # contributors y: 10 # changes flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RowDataSerializer.java x: 3 # contributors y: 4 # changes
12.0
# changes
  min: 1.0
  average: 2.37
  25th percentile: 1.0
  median: 1.0
  75th percentile: 3.0
  max: 12.0
0 8.0
# contributors
min: 1.0 | average: 1.63 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 8.0

Number of Contributors vs. File Size: 125 points

flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 7 # contributors y: 339 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 4 # contributors y: 197 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java x: 3 # contributors y: 450 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 2 # contributors y: 201 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java x: 4 # contributors y: 215 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java x: 6 # contributors y: 96 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 3 # contributors y: 184 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java x: 1 # contributors y: 20 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java x: 1 # contributors y: 44 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java x: 1 # contributors y: 86 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java x: 1 # contributors y: 64 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java x: 1 # contributors y: 236 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java x: 1 # contributors y: 84 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java x: 3 # contributors y: 175 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java x: 2 # contributors y: 16 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/FieldSchema.java x: 2 # contributors y: 44 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/SchemaChangeHelper.java x: 1 # contributors y: 78 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java x: 2 # contributors y: 87 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java x: 1 # contributors y: 191 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java x: 1 # contributors y: 96 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisJsonDebeziumDeserializationSchema.java x: 1 # contributors y: 153 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java x: 2 # contributors y: 176 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java x: 1 # contributors y: 11 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java x: 1 # contributors y: 103 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleSchema.java x: 1 # contributors y: 12 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java x: 1 # contributors y: 81 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java x: 1 # contributors y: 48 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java x: 1 # contributors y: 171 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java x: 1 # contributors y: 170 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java x: 1 # contributors y: 89 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java x: 2 # contributors y: 446 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java x: 2 # contributors y: 100 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java x: 2 # contributors y: 173 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java x: 1 # contributors y: 6 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisType.java x: 1 # contributors y: 24 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/TableSchema.java x: 1 # contributors y: 63 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DateToStringConverter.java x: 1 # contributors y: 116 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java x: 1 # contributors y: 148 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/ParsingProcessFunction.java x: 1 # contributors y: 40 lines of code custom_env.sh.tpl x: 2 # contributors y: 2 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java x: 4 # contributors y: 167 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisInternalException.java x: 3 # contributors y: 8 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/SchemaUtils.java x: 2 # contributors y: 12 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisValueReader.java x: 2 # contributors y: 202 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java x: 8 # contributors y: 491 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java x: 3 # contributors y: 305 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java x: 4 # contributors y: 98 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java x: 4 # contributors y: 238 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplitSerializer.java x: 1 # contributors y: 77 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RowDataSerializer.java x: 3 # contributors y: 121 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisSink.java x: 2 # contributors y: 93 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/EscapeHandler.java x: 2 # contributors y: 39 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisConnectionOptions.java x: 2 # contributors y: 56 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java x: 1 # contributors y: 98 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java x: 2 # contributors y: 58 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Get.java x: 1 # contributors y: 19 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/LookupSchema.java x: 1 # contributors y: 58 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Record.java x: 1 # contributors y: 46 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java x: 1 # contributors y: 109 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java x: 3 # contributors y: 126 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/LoadStatus.java x: 2 # contributors y: 7 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpGetWithEntity.java x: 1 # contributors y: 14 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpPutBuilder.java x: 2 # contributors y: 84 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RowSerializer.java x: 1 # contributors y: 67 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataLookupFunction.java x: 1 # contributors y: 125 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java x: 3 # contributors y: 79 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ConnectedFailedException.java x: 2 # contributors y: 9 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSplitRecords.java x: 1 # contributors y: 49 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java x: 4 # contributors y: 142 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/RowDataDeserializationSchema.java x: 2 # contributors y: 23 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java x: 2 # contributors y: 146 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java x: 2 # contributors y: 105 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSource.java x: 1 # contributors y: 88 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSourceBuilder.java x: 1 # contributors y: 36 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners/SimpleSplitAssigner.java x: 1 # contributors y: 30 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumerator.java x: 1 # contributors y: 57 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisRecordEmitter.java x: 1 # contributors y: 31 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/RespContent.java x: 2 # contributors y: 71 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittableSerializer.java x: 1 # contributors y: 34 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/SimpleStringSerializer.java x: 1 # contributors y: 9 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Backend.java x: 1 # contributors y: 16 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java x: 1 # contributors y: 71 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java x: 1 # contributors y: 51 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/Routing.java x: 1 # contributors y: 41 lines of code
491.0
lines of code
  min: 2.0
  average: 82.31
  25th percentile: 20.0
  median: 51.0
  75th percentile: 104.0
  max: 491.0
0 8.0
# contributors
min: 1.0 | average: 1.63 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 8.0