apache / doris-flink-connector
File Size

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

Intro
Learn more...
File Size Overall
0% | 0% | 30% | 33% | 35%
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% | 0% | 30% | 33% | 35%
tpl0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
flink-doris-connector0% | 0% | 30% | 33% | 35%
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
 491 20
JsonDebeziumSchemaSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 450 29
DorisCatalog.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 446 44
RowBatch.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/serialization
 339 14
DorisRowConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter
 305 17
DorisStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 238 13
DorisBatchStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 236 12
DorisDynamicTableFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 215 8
DorisValueReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
 202 9
DorisConfigOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 201 1
DorisExecutionOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 197 34
DorisSystem.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 191 17
DatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 184 6
MysqlDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 176 5
DorisWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 175 10
DorisTypeMapper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 173 19
ExecutionPool.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 171 9
Worker.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 170 7
BackendClient.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/backend
 167 6
OracleDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 154 4
DorisJsonDebeziumDeserializationSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization
 153 4
MysqlType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 148 1
DorisReadOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 146 30
DorisRowDataInputFormat.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 142 21
DorisDynamicTableSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 126 7
DorisRowDataLookupFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 125 5
RowDataSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 121 11
DateToStringConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 116 8
RecordKey.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 109 6
PartitionDefinition.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
 105 10
RecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 104 8
DorisJdbcLookupReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 104 7
DorisRowDataAsyncLookupFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 104 4
OracleDateConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 103 5
DorisCatalogFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 100 2
DorisCommitter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer
 98 5
DorisLookupOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 98 17
SourceSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 96 11
DorisDynamicTableSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 96 5
DorisSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 93 8
DorisRowDataJdbcLookupFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 89 5
DorisSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source
 88 8
CdcTools.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 87 5
BatchRecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 86 14
Field.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
 85 17
DorisBatchWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 84 7
HttpPutBuilder.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 84 14
OracleType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 81 1
DorisSourceFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/datastream
 79 6
PendingSplitsCheckpointSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator
 78 4
Files With Most Units (Top 50)
File# lines# units
DorisCatalog.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 446 44
DorisExecutionOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 197 34
DorisReadOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 146 30
JsonDebeziumSchemaSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 450 29
DorisRowDataInputFormat.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 142 21
RestService.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
 491 20
DorisTypeMapper.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 173 19
DorisSystem.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 191 17
DorisLookupOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 98 17
Field.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
 85 17
DorisRowConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter
 305 17
TableSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 63 16
Schema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
 71 15
RowBatch.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/serialization
 339 14
BatchRecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 86 14
HttpPutBuilder.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 84 14
DorisStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 238 13
DorisBatchStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 236 12
SourceSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 96 11
FieldSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris
 44 11
RowDataSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 121 11
DorisConnectionOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 56 11
DorisOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 58 11
DorisWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 175 10
Tablet.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
 51 10
PartitionDefinition.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
 105 10
DorisValueReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
 202 9
ExecutionPool.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 171 9
BackendV2.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
 44 9
DateToStringConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 116 8
DorisSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source
 88 8
DorisSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 93 8
RowSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 67 8
RecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 104 8
LookupSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 58 8
DorisDynamicTableFactory.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 215 8
QueryPlan.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
 43 8
DorisSourceSplitReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
 66 7
DorisSourceEnumerator.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/enumerator
 57 7
DorisBatchWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 84 7
DorisCommittable.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 46 7
Worker.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 170 7
DorisJdbcLookupReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 104 7
DorisDynamicTableSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 126 7
RespContent.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
 71 7
BackendRow.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest/models
 39 7
DorisSourceFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/datastream
 79 6
DatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 184 6
ParsingProcessFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 40 6
DorisSplitRecords.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/split
 49 6
Files With Long Lines (Top 43)

There are 43 files with lines longer than 120 characters. In total, there are 118 long lines.

File# lines# units# long lines
RestService.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
 491 20 17
DorisConfigOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 201 1 10
DorisStreamOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 40 4 9
DorisValueReader.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader
 202 9 7
JsonDebeziumSchemaSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 450 29 7
DorisBatchStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 236 12 6
BackendClient.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/backend
 167 6 4
DorisRowConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/converter
 305 17 4
DorisCatalog.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 446 44 3
DorisWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 175 10 3
DorisBatchWriter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 84 7 3
ExecutionPool.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 171 9 3
DorisReadOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 146 30 3
DatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 184 6 2
CdcTools.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc
 87 5 2
OracleType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 81 1 2
MysqlDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 176 5 2
DorisSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink
 93 8 2
DorisStreamLoad.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 238 13 2
DorisCommitter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/committer
 98 5 2
Worker.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 170 7 2
DorisRowDataAsyncLookupFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 104 4 2
OracleDateConverter.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 103 5 1
OracleSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 12 2 1
OracleDatabaseSync.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle
 154 4 1
MysqlType.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 148 1 1
ParsingProcessFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 40 6 1
MysqlSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql
 11 2 1
SimpleJdbcConnectionProvider.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/connection
 48 3 1
ErrorMessages.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/util
 9 - 1
DorisCatalogOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/catalog
 20 1 1
DorisSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/source
 88 8 1
RowDataSerializer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer
 121 11 1
BatchRecordBuffer.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 86 14 1
DorisBatchSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch
 64 3 1
LookupSchema.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/lookup
 58 8 1
DorisExecutionOptions.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/cfg
 197 34 1
DorisRowDataInputFormat.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 142 21 1
DorisDynamicTableSink.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 96 5 1
DorisDynamicTableSource.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 126 7 1
DorisRowDataJdbcLookupFunction.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/table
 89 5 1
DorisInternalException.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/exception
 8 1 1
SchemaUtils.java
in flink-doris-connector/src/main/java/org/apache/doris/flink/rest
 12 1 1
Correlations

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

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

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

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

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

flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 1 commits (30d) y: 339 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 3 commits (30d) y: 197 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java x: 3 commits (30d) y: 450 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 2 commits (30d) y: 201 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java x: 2 commits (30d) y: 215 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java x: 2 commits (30d) y: 96 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 4 commits (30d) y: 184 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java x: 1 commits (30d) y: 20 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java x: 1 commits (30d) y: 44 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java x: 1 commits (30d) y: 86 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java x: 1 commits (30d) y: 64 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java x: 1 commits (30d) y: 236 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java x: 1 commits (30d) y: 84 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java x: 1 commits (30d) y: 175 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java x: 1 commits (30d) y: 16 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/SchemaChangeHelper.java x: 1 commits (30d) y: 78 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java x: 3 commits (30d) y: 87 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java x: 3 commits (30d) y: 191 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java x: 3 commits (30d) y: 96 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisJsonDebeziumDeserializationSchema.java x: 1 commits (30d) y: 153 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java x: 2 commits (30d) y: 176 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java x: 2 commits (30d) y: 154 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java x: 1 commits (30d) y: 11 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java x: 1 commits (30d) y: 103 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java x: 1 commits (30d) y: 81 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java x: 1 commits (30d) y: 48 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisLookupReader.java x: 1 commits (30d) y: 10 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java x: 1 commits (30d) y: 171 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java x: 1 commits (30d) y: 170 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java x: 1 commits (30d) y: 89 lines of code
450.0
lines of code
  min: 10.0
  average: 126.15
  25th percentile: 60.0
  median: 99.5
  75th percentile: 178.0
  max: 450.0
0 4.0
commits (30d)
min: 1.0 | average: 1.53 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 4.0

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

flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 1 contributors (30d) y: 339 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 2 contributors (30d) y: 197 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java x: 2 contributors (30d) y: 450 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 1 contributors (30d) y: 201 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java x: 1 contributors (30d) y: 215 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java x: 1 contributors (30d) y: 96 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 2 contributors (30d) y: 184 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java x: 1 contributors (30d) y: 20 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java x: 1 contributors (30d) y: 44 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java x: 1 contributors (30d) y: 86 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java x: 1 contributors (30d) y: 64 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java x: 1 contributors (30d) y: 236 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java x: 1 contributors (30d) y: 84 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java x: 1 contributors (30d) y: 175 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java x: 1 contributors (30d) y: 16 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/SchemaChangeHelper.java x: 1 contributors (30d) y: 78 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java x: 2 contributors (30d) y: 87 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java x: 1 contributors (30d) y: 191 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisJsonDebeziumDeserializationSchema.java x: 1 contributors (30d) y: 153 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java x: 2 contributors (30d) y: 176 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java x: 1 contributors (30d) y: 11 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java x: 1 contributors (30d) y: 103 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java x: 1 contributors (30d) y: 81 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java x: 1 contributors (30d) y: 48 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisLookupReader.java x: 1 contributors (30d) y: 10 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java x: 1 contributors (30d) y: 171 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java x: 1 contributors (30d) y: 170 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java x: 1 contributors (30d) y: 89 lines of code
450.0
lines of code
  min: 10.0
  average: 126.15
  25th percentile: 60.0
  median: 99.5
  75th percentile: 178.0
  max: 450.0
0 2.0
contributors (30d)
min: 1.0 | average: 1.15 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 2.0

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

flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 2 commits (90d) y: 339 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 4 commits (90d) y: 197 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java x: 3 commits (90d) y: 450 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 3 commits (90d) y: 201 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java x: 2 commits (90d) y: 215 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java x: 2 commits (90d) y: 96 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 6 commits (90d) y: 184 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java x: 1 commits (90d) y: 20 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java x: 1 commits (90d) y: 44 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java x: 1 commits (90d) y: 86 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java x: 1 commits (90d) y: 64 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java x: 1 commits (90d) y: 236 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java x: 1 commits (90d) y: 84 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java x: 3 commits (90d) y: 175 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java x: 1 commits (90d) y: 16 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/FieldSchema.java x: 2 commits (90d) y: 44 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/SchemaChangeHelper.java x: 1 commits (90d) y: 78 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java x: 4 commits (90d) y: 87 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java x: 5 commits (90d) y: 191 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/SourceSchema.java x: 4 commits (90d) y: 96 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisJsonDebeziumDeserializationSchema.java x: 1 commits (90d) y: 153 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java x: 4 commits (90d) y: 176 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDatabaseSync.java x: 2 commits (90d) y: 154 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java x: 1 commits (90d) y: 11 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java x: 1 commits (90d) y: 103 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java x: 1 commits (90d) y: 81 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java x: 1 commits (90d) y: 48 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisLookupReader.java x: 1 commits (90d) y: 10 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java x: 1 commits (90d) y: 171 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java x: 1 commits (90d) y: 170 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java x: 1 commits (90d) y: 89 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java x: 2 commits (90d) y: 446 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java x: 1 commits (90d) y: 100 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java x: 1 commits (90d) y: 173 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java x: 1 commits (90d) y: 6 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisType.java x: 1 commits (90d) y: 24 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/TableSchema.java x: 1 commits (90d) y: 63 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DateToStringConverter.java x: 1 commits (90d) y: 116 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java x: 1 commits (90d) y: 148 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/ParsingProcessFunction.java x: 1 commits (90d) y: 40 lines of code custom_env.sh.tpl x: 1 commits (90d) y: 2 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java x: 1 commits (90d) y: 167 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisInternalException.java x: 1 commits (90d) y: 8 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisValueReader.java x: 1 commits (90d) y: 202 lines of code
450.0
lines of code
  min: 2.0
  average: 114.82
  25th percentile: 24.0
  median: 96.0
  75th percentile: 173.0
  max: 450.0
0 6.0
commits (90d)
min: 1.0 | average: 1.65 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 6.0

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

flink-doris-connector/src/main/java/org/apache/doris/flink/serialization/RowBatch.java x: 2 contributors (90d) y: 339 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/cfg/DorisExecutionOptions.java x: 2 contributors (90d) y: 197 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/JsonDebeziumSchemaSerializer.java x: 2 contributors (90d) y: 450 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisConfigOptions.java x: 1 contributors (90d) y: 201 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableFactory.java x: 1 contributors (90d) y: 215 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSink.java x: 1 contributors (90d) y: 96 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DatabaseSync.java x: 3 contributors (90d) y: 184 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisBatchLoadException.java x: 1 contributors (90d) y: 20 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/BackendUtil.java x: 1 contributors (90d) y: 44 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/BatchRecordBuffer.java x: 1 contributors (90d) y: 86 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchSink.java x: 1 contributors (90d) y: 64 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java x: 1 contributors (90d) y: 236 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchWriter.java x: 1 contributors (90d) y: 84 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisWriter.java x: 2 contributors (90d) y: 175 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/LabelGenerator.java x: 1 contributors (90d) y: 16 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/FieldSchema.java x: 2 contributors (90d) y: 44 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/SchemaChangeHelper.java x: 1 contributors (90d) y: 78 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/CdcTools.java x: 2 contributors (90d) y: 87 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisSystem.java x: 1 contributors (90d) y: 191 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/deserialization/DorisJsonDebeziumDeserializationSchema.java x: 1 contributors (90d) y: 153 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlDatabaseSync.java x: 2 contributors (90d) y: 176 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlSchema.java x: 1 contributors (90d) y: 11 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleDateConverter.java x: 1 contributors (90d) y: 103 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/oracle/OracleType.java x: 1 contributors (90d) y: 81 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/connection/SimpleJdbcConnectionProvider.java x: 1 contributors (90d) y: 48 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/DorisLookupReader.java x: 1 contributors (90d) y: 10 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/ExecutionPool.java x: 1 contributors (90d) y: 171 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java x: 1 contributors (90d) y: 170 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataJdbcLookupFunction.java x: 1 contributors (90d) y: 89 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalog.java x: 1 contributors (90d) y: 446 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisCatalogFactory.java x: 1 contributors (90d) y: 100 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/DorisTypeMapper.java x: 1 contributors (90d) y: 173 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DataModel.java x: 1 contributors (90d) y: 6 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/DorisType.java x: 1 contributors (90d) y: 24 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/catalog/doris/TableSchema.java x: 1 contributors (90d) y: 63 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/DateToStringConverter.java x: 1 contributors (90d) y: 116 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/MysqlType.java x: 1 contributors (90d) y: 148 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/tools/cdc/mysql/ParsingProcessFunction.java x: 1 contributors (90d) y: 40 lines of code custom_env.sh.tpl x: 1 contributors (90d) y: 2 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/backend/BackendClient.java x: 1 contributors (90d) y: 167 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/exception/DorisInternalException.java x: 1 contributors (90d) y: 8 lines of code flink-doris-connector/src/main/java/org/apache/doris/flink/source/reader/DorisValueReader.java x: 1 contributors (90d) y: 202 lines of code
450.0
lines of code
  min: 2.0
  average: 114.82
  25th percentile: 24.0
  median: 96.0
  75th percentile: 173.0
  max: 450.0
0 3.0
contributors (90d)
min: 1.0 | average: 1.18 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 3.0