apache / doris-kafka-connector
File Size

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

Intro
Learn more...
File Size Overall
0% | 0% | 31% | 22% | 46%
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% | 31% | 22% | 46%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
src0% | 0% | 31% | 22% | 46%
Longest Files (Top 50)
File# lines# units
RestService.java
in src/main/java/org/apache/doris/kafka/connector/service
 293 11
RecordService.java
in src/main/java/org/apache/doris/kafka/connector/converter
 290 19
DorisOptions.java
in src/main/java/org/apache/doris/kafka/connector/cfg
 288 40
DorisSinkConnectorConfig.java
in src/main/java/org/apache/doris/kafka/connector/cfg
 281 7
ConfigCheckUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 270 10
CopyLoad.java
in src/main/java/org/apache/doris/kafka/connector/writer/load
 232 9
DorisDefaultSinkService.java
in src/main/java/org/apache/doris/kafka/connector/service
 225 13
RecordDescriptor.java
in src/main/java/org/apache/doris/kafka/connector/converter
 169 27
StreamLoadWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 163 10
DorisWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 152 11
SchemaChangeManager.java
in src/main/java/org/apache/doris/kafka/connector/converter/schema
 149 11
DorisAvroConverter.java
in src/main/java/org/apache/doris/kafka/connector/decode/avro
 142 6
CopyIntoWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 128 9
DorisConnectMonitor.java
in src/main/java/org/apache/doris/kafka/connector/metrics
 121 9
DorisStreamLoad.java
in src/main/java/org/apache/doris/kafka/connector/writer/load
 117 6
Field.java
in src/main/java/org/apache/doris/kafka/connector/model/doris
 105 17
DorisCommitter.java
in src/main/java/org/apache/doris/kafka/connector/writer/commit
 103 3
RecordTypeRegister.java
in src/main/java/org/apache/doris/kafka/connector/converter
 92 4
HttpPutBuilder.java
in src/main/java/org/apache/doris/kafka/connector/utils
 89 15
DorisSinkTask.java
in src/main/java/org/apache/doris/kafka/connector
 86 8
DorisSystemService.java
in src/main/java/org/apache/doris/kafka/connector/service
 82 7
DorisCommittable.java
in src/main/java/org/apache/doris/kafka/connector/writer/commit
 78 11
DateTimeUtils.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/util
 77 18
ArrayType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 77 4
RespContent.java
in src/main/java/org/apache/doris/kafka/connector/model
 74 8
Schema.java
in src/main/java/org/apache/doris/kafka/connector/model/doris
 74 15
MetricsJmxReporter.java
in src/main/java/org/apache/doris/kafka/connector/metrics
 66 6
TableDescriptor.java
in src/main/java/org/apache/doris/kafka/connector/model
 64 14
ColumnDescriptor.java
in src/main/java/org/apache/doris/kafka/connector/model
 57 11
DorisJsonSchema.java
in src/main/java/org/apache/doris/kafka/connector/decode
 57 11
DorisSinkConnector.java
in src/main/java/org/apache/doris/kafka/connector
 57 7
PartitionBuffer.java
in src/main/java/org/apache/doris/kafka/connector/writer
 55 11
JdbcConnectionProvider.java
in src/main/java/org/apache/doris/kafka/connector/connection
 54 3
FileNameUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 53 7
BackendV2.java
in src/main/java/org/apache/doris/kafka/connector/model
 51 10
BackendUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 47 4
CopySQLBuilder.java
in src/main/java/org/apache/doris/kafka/connector/writer
 45 2
HttpPostBuilder.java
in src/main/java/org/apache/doris/kafka/connector/utils
 44 6
ConnectBytesType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 40 3
VariableScaleDecimalType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 39 3
GeoUtils.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/util
 38 2
AbstractType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type
 37 8
LabelGenerator.java
in src/main/java/org/apache/doris/kafka/connector/writer
 34 3
BackoffAndRetryUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 33 1
ZonedTimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 33 1
KafkaRespContent.java
in src/main/java/org/apache/doris/kafka/connector/model
 31 8
ConnectTimeType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 31 1
RecordBuffer.java
in src/main/java/org/apache/doris/kafka/connector/writer
 30 3
SchemaUtils.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/util
 29 5
ConnectDecimalType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/connect
 29 2
Files With Most Units (Top 50)
File# lines# units
DorisOptions.java
in src/main/java/org/apache/doris/kafka/connector/cfg
 288 40
RecordDescriptor.java
in src/main/java/org/apache/doris/kafka/connector/converter
 169 27
RecordService.java
in src/main/java/org/apache/doris/kafka/connector/converter
 290 19
DateTimeUtils.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/util
 77 18
Field.java
in src/main/java/org/apache/doris/kafka/connector/model/doris
 105 17
Schema.java
in src/main/java/org/apache/doris/kafka/connector/model/doris
 74 15
HttpPutBuilder.java
in src/main/java/org/apache/doris/kafka/connector/utils
 89 15
TableDescriptor.java
in src/main/java/org/apache/doris/kafka/connector/model
 64 14
DorisDefaultSinkService.java
in src/main/java/org/apache/doris/kafka/connector/service
 225 13
ColumnDescriptor.java
in src/main/java/org/apache/doris/kafka/connector/model
 57 11
DorisJsonSchema.java
in src/main/java/org/apache/doris/kafka/connector/decode
 57 11
RestService.java
in src/main/java/org/apache/doris/kafka/connector/service
 293 11
DorisCommittable.java
in src/main/java/org/apache/doris/kafka/connector/writer/commit
 78 11
DorisWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 152 11
PartitionBuffer.java
in src/main/java/org/apache/doris/kafka/connector/writer
 55 11
SchemaChangeManager.java
in src/main/java/org/apache/doris/kafka/connector/converter/schema
 149 11
BackendV2.java
in src/main/java/org/apache/doris/kafka/connector/model
 51 10
ConfigCheckUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 270 10
StreamLoadWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 163 10
DorisConnectMonitor.java
in src/main/java/org/apache/doris/kafka/connector/metrics
 121 9
CopyIntoWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 128 9
CopyLoad.java
in src/main/java/org/apache/doris/kafka/connector/writer/load
 232 9
RespContent.java
in src/main/java/org/apache/doris/kafka/connector/model
 74 8
KafkaRespContent.java
in src/main/java/org/apache/doris/kafka/connector/model
 31 8
DorisSinkTask.java
in src/main/java/org/apache/doris/kafka/connector
 86 8
AbstractType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type
 37 8
DorisSinkConnectorConfig.java
in src/main/java/org/apache/doris/kafka/connector/cfg
 281 7
FileNameUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 53 7
DorisSystemService.java
in src/main/java/org/apache/doris/kafka/connector/service
 82 7
DorisSinkConnector.java
in src/main/java/org/apache/doris/kafka/connector
 57 7
MetricsJmxReporter.java
in src/main/java/org/apache/doris/kafka/connector/metrics
 66 6
HttpPostBuilder.java
in src/main/java/org/apache/doris/kafka/connector/utils
 44 6
DorisAvroConverter.java
in src/main/java/org/apache/doris/kafka/connector/decode/avro
 142 6
DorisStreamLoad.java
in src/main/java/org/apache/doris/kafka/connector/writer/load
 117 6
StreamLoadException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 22 5
DataConverterException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 22 5
SchemaChangeException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 22 5
SchemaUtils.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/util
 29 5
BackendUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 47 4
ArgumentsException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 13 4
DataFormatException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 13 4
CopyLoadException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 13 4
DorisException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 13 4
UploadException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 13 4
ArrayType.java
in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium
 77 4
RecordTypeRegister.java
in src/main/java/org/apache/doris/kafka/connector/converter
 92 4
JdbcConnectionProvider.java
in src/main/java/org/apache/doris/kafka/connector/connection
 54 3
CopyIntoResp.java
in src/main/java/org/apache/doris/kafka/connector/model
 18 3
BaseResponse.java
in src/main/java/org/apache/doris/kafka/connector/model
 18 3
ConnectedFailedException.java
in src/main/java/org/apache/doris/kafka/connector/exception
 12 3
Files With Long Lines (Top 6)

There are 6 files with lines longer than 120 characters. In total, there are 9 long lines.

File# lines# units# long lines
CopyIntoWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 128 9 3
RecordService.java
in src/main/java/org/apache/doris/kafka/connector/converter
 290 19 2
ConfigCheckUtils.java
in src/main/java/org/apache/doris/kafka/connector/utils
 270 10 1
DorisSystemService.java
in src/main/java/org/apache/doris/kafka/connector/service
 82 7 1
ResponseUtil.java
in src/main/java/org/apache/doris/kafka/connector/writer
 10 1 1
DorisWriter.java
in src/main/java/org/apache/doris/kafka/connector/writer
 152 11 1
Correlations

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

src/main/java/org/apache/doris/kafka/connector/utils/Version.java x: 4 commits (all time) y: 10 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisOptions.java x: 17 commits (all time) y: 288 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisSinkConnectorConfig.java x: 13 commits (all time) y: 281 lines of code src/main/java/org/apache/doris/kafka/connector/model/BehaviorOnNullValues.java x: 1 commits (all time) y: 15 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java x: 9 commits (all time) y: 225 lines of code src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java x: 11 commits (all time) y: 270 lines of code src/main/java/org/apache/doris/kafka/connector/DorisSinkTask.java x: 6 commits (all time) y: 86 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisSinkServiceFactory.java x: 3 commits (all time) y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java x: 12 commits (all time) y: 290 lines of code src/main/java/org/apache/doris/kafka/connector/model/RespContent.java x: 3 commits (all time) y: 74 lines of code src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java x: 8 commits (all time) y: 152 lines of code src/main/java/org/apache/doris/kafka/connector/writer/load/DorisStreamLoad.java x: 6 commits (all time) y: 117 lines of code src/main/java/org/apache/doris/kafka/connector/DorisSinkConnector.java x: 5 commits (all time) y: 57 lines of code src/main/java/org/apache/doris/kafka/connector/connection/JdbcConnectionProvider.java x: 4 commits (all time) y: 54 lines of code src/main/java/org/apache/doris/kafka/connector/metrics/DorisConnectMonitor.java x: 4 commits (all time) y: 121 lines of code src/main/java/org/apache/doris/kafka/connector/metrics/MetricsJmxReporter.java x: 3 commits (all time) y: 66 lines of code src/main/java/org/apache/doris/kafka/connector/service/RestService.java x: 5 commits (all time) y: 293 lines of code src/main/java/org/apache/doris/kafka/connector/utils/BackoffAndRetryUtils.java x: 3 commits (all time) y: 33 lines of code src/main/java/org/apache/doris/kafka/connector/writer/LabelGenerator.java x: 5 commits (all time) y: 34 lines of code src/main/java/org/apache/doris/kafka/connector/writer/StreamLoadWriter.java x: 9 commits (all time) y: 163 lines of code src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommitter.java x: 4 commits (all time) y: 103 lines of code src/main/java/org/apache/doris/kafka/connector/writer/load/CopyLoad.java x: 3 commits (all time) y: 232 lines of code src/main/java/org/apache/doris/kafka/connector/writer/CopyIntoWriter.java x: 6 commits (all time) y: 128 lines of code src/main/java/org/apache/doris/kafka/connector/converter/RecordDescriptor.java x: 6 commits (all time) y: 169 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/util/GeoUtils.java x: 2 commits (all time) y: 38 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisSinkService.java x: 3 commits (all time) y: 15 lines of code src/main/java/org/apache/doris/kafka/connector/writer/LoadStatus.java x: 3 commits (all time) y: 5 lines of code src/main/java/org/apache/doris/kafka/connector/writer/ResponseUtil.java x: 3 commits (all time) y: 10 lines of code src/main/java/org/apache/doris/kafka/connector/decode/avro/DorisAvroConverter.java x: 2 commits (all time) y: 142 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisSystemService.java x: 4 commits (all time) y: 82 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ZonedTimeType.java x: 2 commits (all time) y: 33 lines of code src/main/java/org/apache/doris/kafka/connector/writer/LoadConstants.java x: 4 commits (all time) y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/writer/load/GroupCommitMode.java x: 1 commits (all time) y: 21 lines of code src/main/java/org/apache/doris/kafka/connector/decode/DorisConverter.java x: 1 commits (all time) y: 14 lines of code src/main/java/org/apache/doris/kafka/connector/decode/DorisJsonSchema.java x: 1 commits (all time) y: 57 lines of code src/main/java/org/apache/doris/kafka/connector/exception/DataDecodeException.java x: 1 commits (all time) y: 12 lines of code src/main/java/org/apache/doris/kafka/connector/utils/BackendUtils.java x: 3 commits (all time) y: 47 lines of code src/main/java/org/apache/doris/kafka/connector/utils/FileNameUtils.java x: 4 commits (all time) y: 53 lines of code src/main/java/org/apache/doris/kafka/connector/converter/ConverterMode.java x: 2 commits (all time) y: 18 lines of code src/main/java/org/apache/doris/kafka/connector/writer/DeliveryGuarantee.java x: 3 commits (all time) y: 18 lines of code src/main/java/org/apache/doris/kafka/connector/converter/RecordTypeRegister.java x: 2 commits (all time) y: 92 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractGeometryType.java x: 1 commits (all time) y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/Type.java x: 3 commits (all time) y: 13 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ArrayType.java x: 1 commits (all time) y: 77 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/GeographyType.java x: 1 commits (all time) y: 10 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/GeometryType.java x: 1 commits (all time) y: 22 lines of code src/main/java/org/apache/doris/kafka/connector/utils/HttpPutBuilder.java x: 3 commits (all time) y: 89 lines of code src/main/java/org/apache/doris/kafka/connector/converter/schema/SchemaChangeManager.java x: 2 commits (all time) y: 149 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractType.java x: 3 commits (all time) y: 37 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectDateType.java x: 3 commits (all time) y: 25 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectTimeType.java x: 3 commits (all time) y: 31 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/util/SchemaUtils.java x: 1 commits (all time) y: 29 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractDateType.java x: 2 commits (all time) y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractTimeType.java x: 2 commits (all time) y: 20 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectBooleanType.java x: 2 commits (all time) y: 14 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectBytesType.java x: 2 commits (all time) y: 40 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectDecimalType.java x: 2 commits (all time) y: 29 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectStringType.java x: 2 commits (all time) y: 24 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/VariableScaleDecimalType.java x: 2 commits (all time) y: 39 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/doris/DorisType.java x: 1 commits (all time) y: 24 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/doris/DorisTypeProperties.java x: 1 commits (all time) y: 7 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/AbstractDebeziumTimeType.java x: 3 commits (all time) y: 22 lines of code src/main/java/org/apache/doris/kafka/connector/model/TableDescriptor.java x: 1 commits (all time) y: 64 lines of code src/main/java/org/apache/doris/kafka/connector/model/doris/Field.java x: 1 commits (all time) y: 105 lines of code src/main/java/org/apache/doris/kafka/connector/model/doris/Schema.java x: 1 commits (all time) y: 74 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractTemporalType.java x: 1 commits (all time) y: 26 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/AbstractConnectMapType.java x: 1 commits (all time) y: 18 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/AbstractConnectSchemaType.java x: 1 commits (all time) y: 3 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/AbstractDebeziumTimestampType.java x: 1 commits (all time) y: 20 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ZonedTimestampType.java x: 1 commits (all time) y: 28 lines of code src/main/java/org/apache/doris/kafka/connector/connection/ConnectionProvider.java x: 2 commits (all time) y: 6 lines of code src/main/java/org/apache/doris/kafka/connector/exception/ArgumentsException.java x: 2 commits (all time) y: 13 lines of code src/main/java/org/apache/doris/kafka/connector/exception/ConnectedFailedException.java x: 2 commits (all time) y: 12 lines of code src/main/java/org/apache/doris/kafka/connector/exception/DataConverterException.java x: 2 commits (all time) y: 22 lines of code src/main/java/org/apache/doris/kafka/connector/model/BackendV2.java x: 2 commits (all time) y: 51 lines of code src/main/java/org/apache/doris/kafka/connector/model/KafkaRespContent.java x: 2 commits (all time) y: 31 lines of code src/main/java/org/apache/doris/kafka/connector/model/LoadOperation.java x: 2 commits (all time) y: 8 lines of code src/main/java/org/apache/doris/kafka/connector/utils/HttpPostBuilder.java x: 2 commits (all time) y: 44 lines of code src/main/java/org/apache/doris/kafka/connector/utils/HttpUtils.java x: 2 commits (all time) y: 19 lines of code src/main/java/org/apache/doris/kafka/connector/writer/CopySQLBuilder.java x: 2 commits (all time) y: 45 lines of code src/main/java/org/apache/doris/kafka/connector/writer/PartitionBuffer.java x: 2 commits (all time) y: 55 lines of code src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommittable.java x: 2 commits (all time) y: 78 lines of code
293.0
lines of code
  min: 3.0
  average: 53.07
  25th percentile: 15.0
  median: 23.0
  75th percentile: 58.75
  max: 293.0
0 17.0
commits (all time)
min: 1.0 | average: 2.9 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 3.0 | max: 17.0

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

src/main/java/org/apache/doris/kafka/connector/utils/Version.java x: 4 contributors (all time) y: 10 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisOptions.java x: 6 contributors (all time) y: 288 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisSinkConnectorConfig.java x: 5 contributors (all time) y: 281 lines of code src/main/java/org/apache/doris/kafka/connector/model/BehaviorOnNullValues.java x: 1 contributors (all time) y: 15 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java x: 4 contributors (all time) y: 225 lines of code src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java x: 6 contributors (all time) y: 270 lines of code src/main/java/org/apache/doris/kafka/connector/DorisSinkTask.java x: 5 contributors (all time) y: 86 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisSinkServiceFactory.java x: 3 contributors (all time) y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java x: 5 contributors (all time) y: 290 lines of code src/main/java/org/apache/doris/kafka/connector/model/RespContent.java x: 3 contributors (all time) y: 74 lines of code src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java x: 5 contributors (all time) y: 152 lines of code src/main/java/org/apache/doris/kafka/connector/writer/load/DorisStreamLoad.java x: 6 contributors (all time) y: 117 lines of code src/main/java/org/apache/doris/kafka/connector/DorisSinkConnector.java x: 4 contributors (all time) y: 57 lines of code src/main/java/org/apache/doris/kafka/connector/connection/JdbcConnectionProvider.java x: 4 contributors (all time) y: 54 lines of code src/main/java/org/apache/doris/kafka/connector/metrics/DorisConnectMonitor.java x: 4 contributors (all time) y: 121 lines of code src/main/java/org/apache/doris/kafka/connector/metrics/MetricsJmxReporter.java x: 3 contributors (all time) y: 66 lines of code src/main/java/org/apache/doris/kafka/connector/service/RestService.java x: 4 contributors (all time) y: 293 lines of code src/main/java/org/apache/doris/kafka/connector/utils/BackoffAndRetryUtils.java x: 3 contributors (all time) y: 33 lines of code src/main/java/org/apache/doris/kafka/connector/writer/LabelGenerator.java x: 4 contributors (all time) y: 34 lines of code src/main/java/org/apache/doris/kafka/connector/writer/StreamLoadWriter.java x: 4 contributors (all time) y: 163 lines of code src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommitter.java x: 4 contributors (all time) y: 103 lines of code src/main/java/org/apache/doris/kafka/connector/writer/load/CopyLoad.java x: 3 contributors (all time) y: 232 lines of code src/main/java/org/apache/doris/kafka/connector/writer/CopyIntoWriter.java x: 4 contributors (all time) y: 128 lines of code src/main/java/org/apache/doris/kafka/connector/converter/RecordDescriptor.java x: 2 contributors (all time) y: 169 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/util/GeoUtils.java x: 2 contributors (all time) y: 38 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisSinkService.java x: 3 contributors (all time) y: 15 lines of code src/main/java/org/apache/doris/kafka/connector/writer/LoadStatus.java x: 3 contributors (all time) y: 5 lines of code src/main/java/org/apache/doris/kafka/connector/writer/ResponseUtil.java x: 3 contributors (all time) y: 10 lines of code src/main/java/org/apache/doris/kafka/connector/decode/avro/DorisAvroConverter.java x: 1 contributors (all time) y: 142 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisSystemService.java x: 2 contributors (all time) y: 82 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ZonedTimeType.java x: 1 contributors (all time) y: 33 lines of code src/main/java/org/apache/doris/kafka/connector/writer/LoadConstants.java x: 4 contributors (all time) y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/writer/load/GroupCommitMode.java x: 1 contributors (all time) y: 21 lines of code src/main/java/org/apache/doris/kafka/connector/decode/DorisConverter.java x: 1 contributors (all time) y: 14 lines of code src/main/java/org/apache/doris/kafka/connector/decode/DorisJsonSchema.java x: 1 contributors (all time) y: 57 lines of code src/main/java/org/apache/doris/kafka/connector/exception/DataDecodeException.java x: 1 contributors (all time) y: 12 lines of code src/main/java/org/apache/doris/kafka/connector/utils/BackendUtils.java x: 3 contributors (all time) y: 47 lines of code src/main/java/org/apache/doris/kafka/connector/utils/FileNameUtils.java x: 3 contributors (all time) y: 53 lines of code src/main/java/org/apache/doris/kafka/connector/converter/ConverterMode.java x: 1 contributors (all time) y: 18 lines of code src/main/java/org/apache/doris/kafka/connector/writer/DeliveryGuarantee.java x: 3 contributors (all time) y: 18 lines of code src/main/java/org/apache/doris/kafka/connector/converter/RecordTypeRegister.java x: 2 contributors (all time) y: 92 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractGeometryType.java x: 1 contributors (all time) y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/Type.java x: 2 contributors (all time) y: 13 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ArrayType.java x: 1 contributors (all time) y: 77 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/GeographyType.java x: 1 contributors (all time) y: 10 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/GeometryType.java x: 1 contributors (all time) y: 22 lines of code src/main/java/org/apache/doris/kafka/connector/utils/HttpPutBuilder.java x: 3 contributors (all time) y: 89 lines of code src/main/java/org/apache/doris/kafka/connector/converter/schema/SchemaChangeManager.java x: 2 contributors (all time) y: 149 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractType.java x: 1 contributors (all time) y: 37 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectDateType.java x: 1 contributors (all time) y: 25 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectTimeType.java x: 1 contributors (all time) y: 31 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/util/SchemaUtils.java x: 1 contributors (all time) y: 29 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractTimeType.java x: 1 contributors (all time) y: 20 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectBytesType.java x: 1 contributors (all time) y: 40 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/ConnectStringType.java x: 1 contributors (all time) y: 24 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/VariableScaleDecimalType.java x: 1 contributors (all time) y: 39 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/doris/DorisTypeProperties.java x: 1 contributors (all time) y: 7 lines of code src/main/java/org/apache/doris/kafka/connector/model/TableDescriptor.java x: 1 contributors (all time) y: 64 lines of code src/main/java/org/apache/doris/kafka/connector/model/doris/Field.java x: 1 contributors (all time) y: 105 lines of code src/main/java/org/apache/doris/kafka/connector/model/doris/Schema.java x: 1 contributors (all time) y: 74 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/AbstractTemporalType.java x: 1 contributors (all time) y: 26 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/connect/AbstractConnectSchemaType.java x: 1 contributors (all time) y: 3 lines of code src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ZonedTimestampType.java x: 1 contributors (all time) y: 28 lines of code src/main/java/org/apache/doris/kafka/connector/connection/ConnectionProvider.java x: 2 contributors (all time) y: 6 lines of code src/main/java/org/apache/doris/kafka/connector/exception/ConnectedFailedException.java x: 2 contributors (all time) y: 12 lines of code src/main/java/org/apache/doris/kafka/connector/exception/DataConverterException.java x: 2 contributors (all time) y: 22 lines of code src/main/java/org/apache/doris/kafka/connector/metrics/MetricsUtil.java x: 2 contributors (all time) y: 18 lines of code src/main/java/org/apache/doris/kafka/connector/model/BackendV2.java x: 2 contributors (all time) y: 51 lines of code src/main/java/org/apache/doris/kafka/connector/model/KafkaRespContent.java x: 2 contributors (all time) y: 31 lines of code src/main/java/org/apache/doris/kafka/connector/model/LoadOperation.java x: 2 contributors (all time) y: 8 lines of code src/main/java/org/apache/doris/kafka/connector/utils/HttpPostBuilder.java x: 2 contributors (all time) y: 44 lines of code src/main/java/org/apache/doris/kafka/connector/utils/HttpUtils.java x: 2 contributors (all time) y: 19 lines of code src/main/java/org/apache/doris/kafka/connector/writer/CopySQLBuilder.java x: 2 contributors (all time) y: 45 lines of code src/main/java/org/apache/doris/kafka/connector/writer/PartitionBuffer.java x: 2 contributors (all time) y: 55 lines of code src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommittable.java x: 2 contributors (all time) y: 78 lines of code
293.0
lines of code
  min: 3.0
  average: 53.07
  25th percentile: 15.0
  median: 23.0
  75th percentile: 58.75
  max: 293.0
0 6.0
contributors (all time)
min: 1.0 | average: 2.04 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 3.0 | max: 6.0

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

src/main/java/org/apache/doris/kafka/connector/utils/Version.java x: 1 commits (30d) y: 10 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisOptions.java x: 2 commits (30d) y: 288 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisSinkConnectorConfig.java x: 2 commits (30d) y: 281 lines of code src/main/java/org/apache/doris/kafka/connector/model/BehaviorOnNullValues.java x: 1 commits (30d) y: 15 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java x: 2 commits (30d) y: 225 lines of code src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java x: 2 commits (30d) y: 270 lines of code src/main/java/org/apache/doris/kafka/connector/DorisSinkTask.java x: 2 commits (30d) y: 86 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisSinkServiceFactory.java x: 1 commits (30d) y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java x: 1 commits (30d) y: 290 lines of code src/main/java/org/apache/doris/kafka/connector/model/RespContent.java x: 1 commits (30d) y: 74 lines of code src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java x: 1 commits (30d) y: 152 lines of code src/main/java/org/apache/doris/kafka/connector/writer/load/DorisStreamLoad.java x: 1 commits (30d) y: 117 lines of code
290.0
lines of code
  min: 9.0
  average: 151.42
  25th percentile: 29.75
  median: 134.5
  75th percentile: 278.25
  max: 290.0
0 2.0
commits (30d)
min: 1.0 | average: 1.42 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 2.0

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

src/main/java/org/apache/doris/kafka/connector/utils/Version.java x: 1 contributors (30d) y: 10 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisOptions.java x: 2 contributors (30d) y: 288 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisSinkConnectorConfig.java x: 2 contributors (30d) y: 281 lines of code src/main/java/org/apache/doris/kafka/connector/model/BehaviorOnNullValues.java x: 1 contributors (30d) y: 15 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java x: 1 contributors (30d) y: 225 lines of code src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java x: 2 contributors (30d) y: 270 lines of code src/main/java/org/apache/doris/kafka/connector/DorisSinkTask.java x: 2 contributors (30d) y: 86 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisSinkServiceFactory.java x: 1 contributors (30d) y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java x: 1 contributors (30d) y: 290 lines of code src/main/java/org/apache/doris/kafka/connector/model/RespContent.java x: 1 contributors (30d) y: 74 lines of code src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java x: 1 contributors (30d) y: 152 lines of code src/main/java/org/apache/doris/kafka/connector/writer/load/DorisStreamLoad.java x: 1 contributors (30d) y: 117 lines of code
290.0
lines of code
  min: 9.0
  average: 151.42
  25th percentile: 29.75
  median: 134.5
  75th percentile: 278.25
  max: 290.0
0 2.0
contributors (30d)
min: 1.0 | average: 1.33 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 2.0

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

src/main/java/org/apache/doris/kafka/connector/utils/Version.java x: 1 commits (90d) y: 10 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisOptions.java x: 2 commits (90d) y: 288 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisSinkConnectorConfig.java x: 2 commits (90d) y: 281 lines of code src/main/java/org/apache/doris/kafka/connector/model/BehaviorOnNullValues.java x: 1 commits (90d) y: 15 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java x: 2 commits (90d) y: 225 lines of code src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java x: 2 commits (90d) y: 270 lines of code src/main/java/org/apache/doris/kafka/connector/DorisSinkTask.java x: 2 commits (90d) y: 86 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisSinkServiceFactory.java x: 1 commits (90d) y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java x: 1 commits (90d) y: 290 lines of code src/main/java/org/apache/doris/kafka/connector/model/RespContent.java x: 1 commits (90d) y: 74 lines of code src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java x: 1 commits (90d) y: 152 lines of code src/main/java/org/apache/doris/kafka/connector/writer/load/DorisStreamLoad.java x: 1 commits (90d) y: 117 lines of code
290.0
lines of code
  min: 9.0
  average: 151.42
  25th percentile: 29.75
  median: 134.5
  75th percentile: 278.25
  max: 290.0
0 2.0
commits (90d)
min: 1.0 | average: 1.42 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 2.0

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

src/main/java/org/apache/doris/kafka/connector/utils/Version.java x: 1 contributors (90d) y: 10 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisOptions.java x: 2 contributors (90d) y: 288 lines of code src/main/java/org/apache/doris/kafka/connector/cfg/DorisSinkConnectorConfig.java x: 2 contributors (90d) y: 281 lines of code src/main/java/org/apache/doris/kafka/connector/model/BehaviorOnNullValues.java x: 1 contributors (90d) y: 15 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java x: 1 contributors (90d) y: 225 lines of code src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java x: 2 contributors (90d) y: 270 lines of code src/main/java/org/apache/doris/kafka/connector/DorisSinkTask.java x: 2 contributors (90d) y: 86 lines of code src/main/java/org/apache/doris/kafka/connector/service/DorisSinkServiceFactory.java x: 1 contributors (90d) y: 9 lines of code src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java x: 1 contributors (90d) y: 290 lines of code src/main/java/org/apache/doris/kafka/connector/model/RespContent.java x: 1 contributors (90d) y: 74 lines of code src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java x: 1 contributors (90d) y: 152 lines of code src/main/java/org/apache/doris/kafka/connector/writer/load/DorisStreamLoad.java x: 1 contributors (90d) y: 117 lines of code
290.0
lines of code
  min: 9.0
  average: 151.42
  25th percentile: 29.75
  median: 134.5
  75th percentile: 278.25
  max: 290.0
0 2.0
contributors (90d)
min: 1.0 | average: 1.33 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 2.0