apache / doris-flink-connector
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
0% | 8% | 38% | 28% | 23%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 8% | 38% | 28% | 23%
xml0% | 0% | 0% | 0% | 100%
tpl0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
flink-doris-connector0% | 8% | 38% | 28% | 23%
tools0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
RestService.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
 639 21
RowBatch.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/serialization
 599 19
DorisBatchStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 520 25
DorisStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 482 18
DorisCatalog.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 478 46
DatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 475 34
BatchStageLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 367 19
DorisRowConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter
 355 20
DorisWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 355 21
SQLParserSchemaManager.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema
 343 18
DorisExecutionOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 339 46
SchemaChangeManager.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema
 311 23
JsonDebeziumSchemaChangeImplV2.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
 289 16
DorisConfigOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 279 1
DorisWriteMetrics.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 275 34
DorisReadOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 274 40
JsonDebeziumSchemaSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer
 269 18
DorisValueReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
 246 9
DorisDynamicTableFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 240 7
DorisTypeMapper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 230 24
MysqlDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 227 8
DorisDynamicTableSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 223 13
BackendClient.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/backend
 222 6
OracleDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 220 7
PostgresDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres
 213 7
MongoJsonDebeziumSchemaChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer
 209 13
Worker.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 208 8
Db2DatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2
 208 7
DorisSchemaFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 207 12
MongoDBDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
 205 11
RowDataSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer
 203 16
CdcTools.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 196 11
SqlServerDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver
 193 7
ExecutionPool.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 187 9
MongoDBJsonDebeziumSchemaSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer
 186 5
MysqlType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 184 1
DorisFlightValueReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
 184 8
SchemaChangeHelper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema
 177 17
DorisJsonDebeziumDeserializationSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/deserialize
 165 4
DorisCopyWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 164 11
DorisDynamicTableSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 159 9
JsonDebeziumSchemaChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
 156 14
DorisSystem.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 151 17
DorisSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 148 14
DorisSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source
 147 14
DorisRowDataInputFormat.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 146 22
DorisCommitter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer
 143 5
DorisBatchWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 142 10
DateToStringConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 141 8
DorisCopyCommitter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 136 6
Files With Most Units (Top 50)
File# lines# units
DorisExecutionOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 339 46
DorisCatalog.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 478 46
DorisReadOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 274 40
DatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 475 34
DorisWriteMetrics.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 275 34
DorisBatchStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 520 25
DorisTypeMapper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 230 24
SchemaChangeManager.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema
 311 23
DorisRowDataInputFormat.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 146 22
DorisWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 355 21
RestService.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
 639 21
TableSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 105 21
DorisRowConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter
 355 20
RespContent.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
 112 20
DorisLookupOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 127 19
BatchRecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 113 19
BatchStageLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 367 19
RowBatch.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/serialization
 599 19
BatchRecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 98 18
SQLParserSchemaManager.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema
 343 18
JsonDebeziumSchemaSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer
 269 18
DorisStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 482 18
SchemaChangeHelper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema
 177 17
JsonDebeziumChangeContext.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
 130 17
DorisSystem.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 151 17
DorisOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 104 16
DorisConnectionOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 88 16
HttpPutBuilder.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 93 16
JsonDebeziumSchemaChangeImplV2.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
 289 16
RowDataSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer
 203 16
Field.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
 87 15
SourceSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 95 14
DorisSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 148 14
JsonDebeziumSchemaChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium
 156 14
DorisSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source
 147 14
MongoJsonDebeziumSchemaChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer
 209 13
DorisDynamicTableSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 223 13
Schema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
 68 13
ArrowSerializer.java
in flink-doris-connector/src/main/java/org/apache/flink/table/runtime/arrow/serializers
 84 12
PartitionDefinition.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
 132 12
FieldSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 60 12
DorisSchemaFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 207 12
MongoDBDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
 205 11
CdcTools.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 196 11
DorisCopyWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 164 11
DorisRecord.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer
 55 11
MongoDBSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb
 130 10
IPUtils.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/util
 126 10
RecordWithMeta.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 47 10
DorisBatchWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 142 10
Files With Long Lines (Top 14)

There are 14 files with lines longer than 120 characters. In total, there are 23 long lines.

File# lines# units# long lines
DorisConfigOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 279 1 10
MongoJsonDebeziumDataChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer
 116 6 1
MongoJsonDebeziumSchemaChange.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer
 209 13 1
MysqlDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 227 8 1
DatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 475 34 1
OracleDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 220 7 1
DorisRowConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter
 355 20 1
BatchStageLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy
 367 19 1
ResponseUtil.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 23 3 1
SchemaChangeHelper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema
 177 17 1
DorisWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 355 21 1
DorisValueReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
 246 9 1
DorisSystem.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 151 17 1
DorisCatalog.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 478 46 1
Correlations

File Size vs. Commits (all time): 196 points

flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java x: 4 commits (all time) y: 105 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java x: 7 commits (all time) y: 118 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 51 commits (all time) y: 475 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java x: 10 commits (all time) y: 205 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java x: 5 commits (all time) y: 130 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java x: 5 commits (all time) y: 186 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java x: 4 commits (all time) y: 116 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java x: 4 commits (all time) y: 209 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java x: 1 commits (all time) y: 63 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java x: 1 commits (all time) y: 30 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java x: 8 commits (all time) y: 156 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java x: 15 commits (all time) y: 289 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java x: 7 commits (all time) y: 98 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 24 commits (all time) y: 339 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java x: 2 commits (all time) y: 22 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java x: 29 commits (all time) y: 482 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java x: 31 commits (all time) y: 355 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java x: 8 commits (all time) y: 26 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java x: 4 commits (all time) y: 103 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java x: 4 commits (all time) y: 42 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 26 commits (all time) y: 279 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java x: 23 commits (all time) y: 520 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 26 commits (all time) y: 599 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java x: 8 commits (all time) y: 35 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java x: 12 commits (all time) y: 274 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java x: 27 commits (all time) y: 639 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/ValueReader.java x: 4 commits (all time) y: 35 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java x: 3 commits (all time) y: 7 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java x: 7 commits (all time) y: 208 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactory.java x: 5 commits (all time) y: 207 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java x: 20 commits (all time) y: 269 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeContext.java x: 6 commits (all time) y: 130 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java x: 5 commits (all time) y: 57 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter/TableNameConverter.java x: 1 commits (all time) y: 37 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java x: 3 commits (all time) y: 23 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java x: 10 commits (all time) y: 75 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java x: 10 commits (all time) y: 142 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisFlightValueReader.java x: 3 commits (all time) y: 184 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisValueReader.java x: 8 commits (all time) y: 246 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java x: 20 commits (all time) y: 223 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/BackendV2.java x: 5 commits (all time) y: 52 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java x: 4 commits (all time) y: 87 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java x: 4 commits (all time) y: 31 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java x: 4 commits (all time) y: 68 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java x: 15 commits (all time) y: 159 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SQLParserSchemaManager.java x: 6 commits (all time) y: 343 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java x: 12 commits (all time) y: 63 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/CdcSchemaChange.java x: 2 commits (all time) y: 9 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java x: 14 commits (all time) y: 143 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java x: 18 commits (all time) y: 220 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java x: 5 commits (all time) y: 132 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSource.java x: 10 commits (all time) y: 147 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisExpressionVisitor.java x: 3 commits (all time) y: 126 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DorisTableConfig.java x: 4 commits (all time) y: 78 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/JdbcSourceSchema.java x: 5 commits (all time) y: 93 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java x: 12 commits (all time) y: 95 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java x: 11 commits (all time) y: 213 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/TableSchema.java x: 6 commits (all time) y: 105 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java x: 24 commits (all time) y: 196 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeHelper.java x: 10 commits (all time) y: 177 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java x: 6 commits (all time) y: 222 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/assigners/SimpleSplitAssigner.java x: 5 commits (all time) y: 35 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java x: 3 commits (all time) y: 26 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisOptions.java x: 11 commits (all time) y: 104 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisSink.java x: 13 commits (all time) y: 148 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/IllegalArgumentException.java x: 2 commits (all time) y: 12 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeManager.java x: 12 commits (all time) y: 311 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java x: 11 commits (all time) y: 101 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSyncConfig.java x: 3 commits (all time) y: 66 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumerator.java x: 4 commits (all time) y: 58 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceReader.java x: 3 commits (all time) y: 50 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceSplitReader.java x: 6 commits (all time) y: 80 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java x: 20 commits (all time) y: 151 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java x: 4 commits (all time) y: 51 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java x: 9 commits (all time) y: 184 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpPutBuilder.java x: 6 commits (all time) y: 93 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchBufferHttpEntity.java x: 1 commits (all time) y: 48 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchBufferStream.java x: 1 commits (all time) y: 47 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java x: 6 commits (all time) y: 98 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchRecordBuffer.java x: 1 commits (all time) y: 113 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java x: 5 commits (all time) y: 367 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisStreamOptions.java x: 4 commits (all time) y: 106 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/SchemaUtils.java x: 4 commits (all time) y: 45 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSplitRecords.java x: 4 commits (all time) y: 48 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java x: 26 commits (all time) y: 240 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java x: 2 commits (all time) y: 208 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java x: 18 commits (all time) y: 227 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java x: 11 commits (all time) y: 193 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Schema.java x: 2 commits (all time) y: 31 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/CopySQLBuilder.java x: 3 commits (all time) y: 68 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumDataChange.java x: 4 commits (all time) y: 95 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java x: 12 commits (all time) y: 478 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeUtils.java x: 5 commits (all time) y: 71 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceConnector.java x: 4 commits (all time) y: 16 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DateConverter.java x: 1 commits (all time) y: 104 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Type.java x: 1 commits (all time) y: 71 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDateConverter.java x: 2 commits (all time) y: 17 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java x: 4 commits (all time) y: 141 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDateConverter.java x: 4 commits (all time) y: 85 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/deserialize/DorisJsonDebeziumDeserializationSchema.java x: 2 commits (all time) y: 165 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java x: 15 commits (all time) y: 230 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisType.java x: 5 commits (all time) y: 31 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeMode.java x: 1 commits (all time) y: 12 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImpl.java x: 3 commits (all time) y: 115 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyWriter.java x: 4 commits (all time) y: 164 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisConnectionOptions.java x: 7 commits (all time) y: 88 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java x: 6 commits (all time) y: 85 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java x: 5 commits (all time) y: 10 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/RowDataDeserializationSchema.java x: 4 commits (all time) y: 25 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/RespContent.java x: 6 commits (all time) y: 112 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecordSerializer.java x: 5 commits (all time) y: 13 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RecordWithMetaSerializer.java x: 4 commits (all time) y: 29 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowDataSerializer.java x: 5 commits (all time) y: 203 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowSerializer.java x: 4 commits (all time) y: 74 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/SimpleStringSerializer.java x: 4 commits (all time) y: 11 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java x: 7 commits (all time) y: 99 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisLookupOptions.java x: 4 commits (all time) y: 127 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/CreateTableException.java x: 3 commits (all time) y: 9 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java x: 3 commits (all time) y: 15 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisSystemException.java x: 3 commits (all time) y: 12 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/LookupMetrics.java x: 1 commits (all time) y: 26 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java x: 5 commits (all time) y: 108 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/ResponseUtil.java x: 5 commits (all time) y: 23 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/RecordWithMeta.java x: 3 commits (all time) y: 47 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/util/IPUtils.java x: 1 commits (all time) y: 126 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java x: 7 commits (all time) y: 93 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java x: 4 commits (all time) y: 89 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommitter.java x: 2 commits (all time) y: 136 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java x: 12 commits (all time) y: 355 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresSchema.java x: 4 commits (all time) y: 22 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/CopyLoadException.java x: 1 commits (all time) y: 22 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisAbstractCommittable.java x: 1 commits (all time) y: 2 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittable.java x: 3 commits (all time) y: 51 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BackoffAndRetryUtils.java x: 1 commits (all time) y: 43 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/CopyCommittableSerializer.java x: 1 commits (all time) y: 40 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/models/BaseResponse.java x: 1 commits (all time) y: 18 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisAbstractWriter.java x: 1 commits (all time) y: 6 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/WriteMode.java x: 1 commits (all time) y: 13 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriteMetrics.java x: 1 commits (all time) y: 275 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/ChangeEvent.java x: 1 commits (all time) y: 3 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecord.java x: 4 commits (all time) y: 55 lines of code flink-doris-connector/src/main/java/org/apache/flink/table/runtime/arrow/serializers/ArrowSerializer.java x: 1 commits (all time) y: 84 lines of code tools/maven/suppressions.xml x: 2 commits (all time) y: 7 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisJdbcLookupReader.java x: 3 commits (all time) y: 106 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java x: 4 commits (all time) y: 187 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/LookupSchema.java x: 2 commits (all time) y: 69 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Record.java x: 2 commits (all time) y: 43 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java x: 2 commits (all time) y: 109 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisCommittableSerializer.java x: 2 commits (all time) y: 34 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/EscapeHandler.java x: 3 commits (all time) y: 39 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpGetWithEntity.java x: 2 commits (all time) y: 14 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/CacheRecordBuffer.java x: 2 commits (all time) y: 87 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterState.java x: 3 commits (all time) y: 63 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterStateSerializer.java x: 3 commits (all time) y: 41 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java x: 7 commits (all time) y: 146 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisInternalException.java x: 4 commits (all time) y: 14 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java x: 3 commits (all time) y: 2 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/Routing.java x: 2 commits (all time) y: 38 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/PendingSplitsCheckpointSerializer.java x: 2 commits (all time) y: 80 lines of code custom_env.sh.tpl x: 2 commits (all time) y: 2 lines of code
639.0
lines of code
  min: 2.0
  average: 104.26
  25th percentile: 23.0
  median: 70.0
  75th percentile: 139.75
  max: 639.0
0 51.0
commits (all time)
min: 1.0 | average: 5.99 | 25th percentile: 2.0 | median: 4.0 | 75th percentile: 6.0 | max: 51.0

File Size vs. Contributors (all time): 196 points

flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java x: 3 contributors (all time) y: 105 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java x: 5 contributors (all time) y: 118 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 10 contributors (all time) y: 475 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java x: 7 contributors (all time) y: 205 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java x: 3 contributors (all time) y: 130 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java x: 4 contributors (all time) y: 186 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumDataChange.java x: 4 contributors (all time) y: 116 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java x: 3 contributors (all time) y: 209 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java x: 1 contributors (all time) y: 63 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java x: 1 contributors (all time) y: 30 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java x: 3 contributors (all time) y: 156 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java x: 3 contributors (all time) y: 289 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java x: 2 contributors (all time) y: 98 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 7 contributors (all time) y: 339 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java x: 1 contributors (all time) y: 22 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java x: 6 contributors (all time) y: 482 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java x: 7 contributors (all time) y: 355 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java x: 5 contributors (all time) y: 26 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java x: 4 contributors (all time) y: 103 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java x: 4 contributors (all time) y: 42 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 6 contributors (all time) y: 279 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java x: 7 contributors (all time) y: 520 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 12 contributors (all time) y: 599 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java x: 4 contributors (all time) y: 35 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java x: 4 contributors (all time) y: 274 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java x: 11 contributors (all time) y: 639 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/ValueReader.java x: 2 contributors (all time) y: 35 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java x: 2 contributors (all time) y: 7 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java x: 3 contributors (all time) y: 208 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSchemaFactory.java x: 2 contributors (all time) y: 207 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java x: 3 contributors (all time) y: 269 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java x: 3 contributors (all time) y: 57 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter/TableNameConverter.java x: 1 contributors (all time) y: 37 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java x: 2 contributors (all time) y: 23 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java x: 4 contributors (all time) y: 75 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java x: 4 contributors (all time) y: 142 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisFlightValueReader.java x: 2 contributors (all time) y: 184 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisValueReader.java x: 3 contributors (all time) y: 246 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java x: 7 contributors (all time) y: 223 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/ChangeStreamConstant.java x: 2 contributors (all time) y: 21 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/BackendV2.java x: 3 contributors (all time) y: 52 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Field.java x: 3 contributors (all time) y: 87 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/QueryPlan.java x: 3 contributors (all time) y: 31 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Schema.java x: 3 contributors (all time) y: 68 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/Tablet.java x: 3 contributors (all time) y: 34 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java x: 7 contributors (all time) y: 159 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SQLParserSchemaManager.java x: 2 contributors (all time) y: 343 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java x: 3 contributors (all time) y: 63 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/CdcSchemaChange.java x: 2 contributors (all time) y: 9 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer/DorisCommitter.java x: 5 contributors (all time) y: 143 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java x: 4 contributors (all time) y: 220 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/PartitionDefinition.java x: 3 contributors (all time) y: 132 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSource.java x: 4 contributors (all time) y: 147 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSourceSplit.java x: 2 contributors (all time) y: 42 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisExpressionVisitor.java x: 2 contributors (all time) y: 126 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DorisTableConfig.java x: 2 contributors (all time) y: 78 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/JdbcSourceSchema.java x: 3 contributors (all time) y: 93 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java x: 4 contributors (all time) y: 95 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDatabaseSync.java x: 4 contributors (all time) y: 213 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java x: 6 contributors (all time) y: 196 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeHelper.java x: 3 contributors (all time) y: 177 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java x: 4 contributors (all time) y: 222 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisTableInputSplit.java x: 3 contributors (all time) y: 26 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisSink.java x: 3 contributors (all time) y: 148 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/IllegalArgumentException.java x: 2 contributors (all time) y: 12 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeManager.java x: 3 contributors (all time) y: 311 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSyncConfig.java x: 3 contributors (all time) y: 66 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator/DorisSourceEnumerator.java x: 2 contributors (all time) y: 58 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceReader.java x: 2 contributors (all time) y: 50 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceSplitReader.java x: 3 contributors (all time) y: 80 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java x: 5 contributors (all time) y: 151 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java x: 2 contributors (all time) y: 51 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java x: 5 contributors (all time) y: 184 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchBufferHttpEntity.java x: 1 contributors (all time) y: 48 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchBufferStream.java x: 1 contributors (all time) y: 47 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java x: 3 contributors (all time) y: 98 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchRecordBuffer.java x: 1 contributors (all time) y: 113 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BatchStageLoad.java x: 1 contributors (all time) y: 367 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisStreamOptions.java x: 4 contributors (all time) y: 106 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/SchemaUtils.java x: 3 contributors (all time) y: 45 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/split/DorisSplitRecords.java x: 3 contributors (all time) y: 48 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java x: 8 contributors (all time) y: 240 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DatabaseSync.java x: 1 contributors (all time) y: 208 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java x: 5 contributors (all time) y: 227 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDatabaseSync.java x: 4 contributors (all time) y: 193 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Schema.java x: 1 contributors (all time) y: 31 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/CopySQLBuilder.java x: 2 contributors (all time) y: 68 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumDataChange.java x: 3 contributors (all time) y: 95 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java x: 4 contributors (all time) y: 478 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumChangeUtils.java x: 2 contributors (all time) y: 71 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceConnector.java x: 2 contributors (all time) y: 16 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2DateConverter.java x: 1 contributors (all time) y: 104 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/db2/Db2Type.java x: 1 contributors (all time) y: 71 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/DateToStringConverter.java x: 2 contributors (all time) y: 141 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java x: 2 contributors (all time) y: 118 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresDateConverter.java x: 2 contributors (all time) y: 104 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerDateConverter.java x: 2 contributors (all time) y: 85 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/deserialize/DorisJsonDebeziumDeserializationSchema.java x: 1 contributors (all time) y: 165 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java x: 6 contributors (all time) y: 230 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/schema/SchemaChangeMode.java x: 1 contributors (all time) y: 12 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImpl.java x: 1 contributors (all time) y: 115 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyWriter.java x: 2 contributors (all time) y: 164 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/datastream/DorisSourceFunction.java x: 4 contributors (all time) y: 85 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisDeserializationSchema.java x: 4 contributors (all time) y: 10 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/RowDataDeserializationSchema.java x: 3 contributors (all time) y: 25 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/SimpleListDeserializationSchema.java x: 3 contributors (all time) y: 17 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models/RespContent.java x: 5 contributors (all time) y: 112 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecordSerializer.java x: 3 contributors (all time) y: 13 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RecordWithMetaSerializer.java x: 2 contributors (all time) y: 29 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowDataSerializer.java x: 3 contributors (all time) y: 203 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/RowSerializer.java x: 2 contributors (all time) y: 74 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java x: 4 contributors (all time) y: 99 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java x: 2 contributors (all time) y: 15 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/StreamLoadException.java x: 3 contributors (all time) y: 9 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/LookupMetrics.java x: 1 contributors (all time) y: 26 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java x: 2 contributors (all time) y: 129 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java x: 2 contributors (all time) y: 108 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/RecordWithMeta.java x: 2 contributors (all time) y: 47 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/util/IPUtils.java x: 1 contributors (all time) y: 126 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/sqlserver/SqlServerType.java x: 4 contributors (all time) y: 93 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleSchema.java x: 4 contributors (all time) y: 31 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java x: 4 contributors (all time) y: 89 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/DorisCopyCommitter.java x: 1 contributors (all time) y: 136 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter/DorisRowConverter.java x: 5 contributors (all time) y: 355 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresSchema.java x: 3 contributors (all time) y: 22 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/DorisAbstractCommittable.java x: 1 contributors (all time) y: 2 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/BackoffAndRetryUtils.java x: 1 contributors (all time) y: 43 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/CopyCommittableSerializer.java x: 1 contributors (all time) y: 40 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/copy/models/BaseResponse.java x: 1 contributors (all time) y: 18 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisAbstractWriter.java x: 1 contributors (all time) y: 6 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/WriteMode.java x: 1 contributors (all time) y: 13 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriteMetrics.java x: 1 contributors (all time) y: 275 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/ChangeEvent.java x: 1 contributors (all time) y: 3 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/DorisRecord.java x: 3 contributors (all time) y: 55 lines of code flink-doris-connector/src/main/java/org/apache/flink/table/runtime/arrow/serializers/ArrowSerializer.java x: 1 contributors (all time) y: 84 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java x: 2 contributors (all time) y: 187 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Record.java x: 2 contributors (all time) y: 43 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/RecordKey.java x: 2 contributors (all time) y: 109 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/EscapeHandler.java x: 3 contributors (all time) y: 39 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/CacheRecordBuffer.java x: 2 contributors (all time) y: 87 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriterStateSerializer.java x: 3 contributors (all time) y: 41 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataInputFormat.java x: 5 contributors (all time) y: 146 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/ShouldNeverHappenException.java x: 3 contributors (all time) y: 2 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/Routing.java x: 2 contributors (all time) y: 38 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisRecordEmitter.java x: 2 contributors (all time) y: 31 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisLookupReader.java x: 1 contributors (all time) y: 10 lines of code custom_env.sh.tpl x: 2 contributors (all time) y: 2 lines of code
639.0
lines of code
  min: 2.0
  average: 104.26
  25th percentile: 23.0
  median: 70.0
  75th percentile: 139.75
  max: 639.0
0 12.0
contributors (all time)
min: 1.0 | average: 2.83 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 3.0 | max: 12.0

File Size vs. Commits (30 days): 1 points

flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java x: 1 commits (30d) y: 105 lines of code
105.0
lines of code
  min: 105.0
  average: 105.0
  25th percentile: 105.0
  median: 105.0
  75th percentile: 105.0
  max: 105.0
0 1.0
commits (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

File Size vs. Contributors (30 days): 1 points

flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java x: 1 contributors (30d) y: 105 lines of code
105.0
lines of code
  min: 105.0
  average: 105.0
  25th percentile: 105.0
  median: 105.0
  75th percentile: 105.0
  max: 105.0
0 1.0
contributors (30d)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

File Size vs. Commits (90 days): 41 points

flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java x: 2 commits (90d) y: 105 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java x: 1 commits (90d) y: 118 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 2 commits (90d) y: 475 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java x: 1 commits (90d) y: 205 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java x: 1 commits (90d) y: 130 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java x: 1 commits (90d) y: 186 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java x: 2 commits (90d) y: 209 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java x: 1 commits (90d) y: 63 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java x: 1 commits (90d) y: 30 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java x: 2 commits (90d) y: 156 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java x: 2 commits (90d) y: 289 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java x: 2 commits (90d) y: 98 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 2 commits (90d) y: 339 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java x: 1 commits (90d) y: 22 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java x: 1 commits (90d) y: 482 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java x: 2 commits (90d) y: 355 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java x: 1 commits (90d) y: 26 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java x: 1 commits (90d) y: 103 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java x: 1 commits (90d) y: 42 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 3 commits (90d) y: 279 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java x: 3 commits (90d) y: 520 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 2 commits (90d) y: 599 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java x: 1 commits (90d) y: 35 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java x: 3 commits (90d) y: 274 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java x: 2 commits (90d) y: 639 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java x: 1 commits (90d) y: 7 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java x: 1 commits (90d) y: 208 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java x: 1 commits (90d) y: 269 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java x: 1 commits (90d) y: 57 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter/TableNameConverter.java x: 1 commits (90d) y: 37 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java x: 1 commits (90d) y: 23 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java x: 1 commits (90d) y: 75 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java x: 1 commits (90d) y: 142 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisValueReader.java x: 1 commits (90d) y: 246 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java x: 2 commits (90d) y: 223 lines of code
639.0
lines of code
  min: 7.0
  average: 189.24
  25th percentile: 49.5
  median: 142.0
  75th percentile: 271.5
  max: 639.0
0 3.0
commits (90d)
min: 1.0 | average: 1.41 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 3.0

File Size vs. Contributors (90 days): 41 points

flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBType.java x: 2 contributors (90d) y: 105 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/postgres/PostgresType.java x: 1 contributors (90d) y: 118 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 2 contributors (90d) y: 475 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBDatabaseSync.java x: 1 contributors (90d) y: 205 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoDBSchema.java x: 1 contributors (90d) y: 130 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoDBJsonDebeziumSchemaSerializer.java x: 1 contributors (90d) y: 186 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/serializer/MongoJsonDebeziumSchemaChange.java x: 2 contributors (90d) y: 209 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/DorisTableUtil.java x: 1 contributors (90d) y: 63 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/utils/JsonNodeExtractUtil.java x: 1 contributors (90d) y: 30 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChange.java x: 1 contributors (90d) y: 156 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/JsonDebeziumSchemaChangeImplV2.java x: 1 contributors (90d) y: 289 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/jsondebezium/SQLParserSchemaChange.java x: 1 contributors (90d) y: 98 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 1 contributors (90d) y: 339 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/LabelAlreadyExistsException.java x: 1 contributors (90d) y: 22 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java x: 1 contributors (90d) y: 482 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java x: 1 contributors (90d) y: 355 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LoadConstants.java x: 1 contributors (90d) y: 26 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordBuffer.java x: 1 contributors (90d) y: 103 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/RecordStream.java x: 1 contributors (90d) y: 42 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 1 contributors (90d) y: 279 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java x: 2 contributors (90d) y: 520 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 2 contributors (90d) y: 599 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/ConfigurationOptions.java x: 1 contributors (90d) y: 35 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisReadOptions.java x: 1 contributors (90d) y: 274 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java x: 1 contributors (90d) y: 639 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java x: 1 contributors (90d) y: 7 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java x: 1 contributors (90d) y: 208 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/serializer/JsonDebeziumSchemaSerializer.java x: 1 contributors (90d) y: 269 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/ParsingProcessFunction.java x: 1 contributors (90d) y: 57 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/converter/TableNameConverter.java x: 1 contributors (90d) y: 37 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mongodb/MongoParsingProcessFunction.java x: 1 contributors (90d) y: 23 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/HttpUtil.java x: 1 contributors (90d) y: 75 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java x: 1 contributors (90d) y: 142 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisValueReader.java x: 1 contributors (90d) y: 246 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java x: 1 contributors (90d) y: 223 lines of code
639.0
lines of code
  min: 7.0
  average: 189.24
  25th percentile: 49.5
  median: 142.0
  75th percentile: 271.5
  max: 639.0
0 2.0
contributors (90d)
min: 1.0 | average: 1.12 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 2.0