apache / doris-kafka-connector

Intro

Unit size measurements show the distribution of size of units of code (methods, functions...).
Units are classified in four categories based on their size (lines of code): 1-20 (small units), 20-50 (medium size units), 51-100 (long units), 101+ (very long units).
You should aim at keeping units small (< 20 lines). Long units may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.

Learn more...

Unit Size Overall

There are 547 units with 4,167 lines of code in units (68.9% of code).

2 very long units (297 lines of code)
5 long units (322 lines of code)
31 medium size units (857 lines of code)
64 small units (920 lines of code)
445 very small units (1,771 lines of code)

Legend:

101+

51-100

21-50

11-20

1-10

Unit Size per Extension

101+

51-100

21-50

11-20

1-10

Unit Size per Logical Component

primary logical decomposition

101+

51-100

21-50

11-20

1-10

Alternative Visuals

3D view of all units

Longest Units

Top 50 longest units

Unit	# lines	McCabe index	# params
public static ConfigDef newConfigDef() in src/main/java/org/apache/doris/kafka/connector/cfg/DorisSinkConnectorConfig.java	154	1	0
public static String validateConfig() in src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java	143	31	1
private static String send() in src/main/java/org/apache/doris/kafka/connector/service/RestService.java	81	7	3
public DorisOptions() in src/main/java/org/apache/doris/kafka/connector/cfg/DorisOptions.java	73	7	1
private void commitTransaction() in src/main/java/org/apache/doris/kafka/connector/writer/commit/DorisCommitter.java	60	7	1
public void load() in src/main/java/org/apache/doris/kafka/connector/writer/load/DorisStreamLoad.java	56	10	2
public boolean executeCopy() in src/main/java/org/apache/doris/kafka/connector/writer/load/CopyLoad.java	52	5	1
private void registerJMXMetrics() in src/main/java/org/apache/doris/kafka/connector/metrics/DorisConnectMonitor.java	49	2	1
public void parseTopic2Schema() in src/main/java/org/apache/doris/kafka/connector/decode/avro/DorisAvroConverter.java	43	5	1
public String getUploadAddress() in src/main/java/org/apache/doris/kafka/connector/writer/load/CopyLoad.java	43	4	1
public String processStructRecord() in src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java	36	4	1
public void upLoadFile() in src/main/java/org/apache/doris/kafka/connector/writer/load/CopyLoad.java	33	4	3
public DorisWriter() in src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java	32	3	6
private String parseFieldValues() in src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java	30	7	4
protected void registerTypes() in src/main/java/org/apache/doris/kafka/connector/converter/RecordTypeRegister.java	30	1	0
public static Map parseTopicToTableMap() in src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java	29	8	1
public Map fetchLabel2Status() in src/main/java/org/apache/doris/kafka/connector/writer/StreamLoadWriter.java	28	3	0
public static boolean validateGroupCommitMode() in src/main/java/org/apache/doris/kafka/connector/utils/ConfigCheckUtils.java	27	8	1
private String parseRecordTableName() in src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java	27	6	3
private static List parseBackendV2() in src/main/java/org/apache/doris/kafka/connector/service/RestService.java	26	5	2
public List listLoadFiles() in src/main/java/org/apache/doris/kafka/connector/writer/CopyIntoWriter.java	26	3	0
public Object getValue() in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ArrayType.java	26	7	2
private Map parseTopicSchemaPath() in src/main/java/org/apache/doris/kafka/connector/decode/avro/DorisAvroConverter.java	25	7	1
public List extractColumnValuesBySQL() in src/main/java/org/apache/doris/kafka/connector/service/DorisSystemService.java	25	8	4
public boolean shouldSkipRecord() in src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java	25	4	1
private void alterTableIfNeeded() in src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java	25	4	2
public void startTask() in src/main/java/org/apache/doris/kafka/connector/service/DorisDefaultSinkService.java	24	3	2
protected void insertRecord() in src/main/java/org/apache/doris/kafka/connector/writer/DorisWriter.java	24	7	1
public String buildCopySQL() in src/main/java/org/apache/doris/kafka/connector/writer/CopySQLBuilder.java	24	2	0
public SchemaAndValue toConnectData() in src/main/java/org/apache/doris/kafka/connector/decode/avro/DorisAvroConverter.java	23	4	2
public static List getBackendsV2() in src/main/java/org/apache/doris/kafka/connector/service/RestService.java	23	4	2
private static String getConnectionPost() in src/main/java/org/apache/doris/kafka/connector/service/RestService.java	23	1	4
public boolean handleCommitResponse() in src/main/java/org/apache/doris/kafka/connector/writer/load/CopyLoad.java	23	5	1
public void addColumnDDL() in src/main/java/org/apache/doris/kafka/connector/converter/schema/SchemaChangeManager.java	23	3	2
public static Object handleGeoStructData() in src/main/java/org/apache/doris/kafka/connector/converter/type/util/GeoUtils.java	22	3	1
public static Object backoffAndRetry() in src/main/java/org/apache/doris/kafka/connector/utils/BackoffAndRetryUtils.java	21	4	2
public Map preCommit() in src/main/java/org/apache/doris/kafka/connector/DorisSinkTask.java	21	5	1
private TableDescriptor obtainTableSchema() in src/main/java/org/apache/doris/kafka/connector/converter/RecordService.java	21	1	1
public Connection getOrEstablishConnection() in src/main/java/org/apache/doris/kafka/connector/connection/JdbcConnectionProvider.java	20	6	0
private static Map handleResponse() in src/main/java/org/apache/doris/kafka/connector/service/RestService.java	20	4	2
protected void flush() in src/main/java/org/apache/doris/kafka/connector/writer/CopyIntoWriter.java	20	2	1
public static String buildAddColumnDDL() in src/main/java/org/apache/doris/kafka/connector/converter/schema/SchemaChangeManager.java	20	3	3
private Map handleResponse() in src/main/java/org/apache/doris/kafka/connector/converter/schema/SchemaChangeManager.java	20	4	2
public static void setDefaultValues() in src/main/java/org/apache/doris/kafka/connector/cfg/DorisSinkConnectorConfig.java	19	1	1
public String getTypeName() in src/main/java/org/apache/doris/kafka/connector/converter/type/debezium/ArrayType.java	19	5	1
private static ObjectName getObjectName() in src/main/java/org/apache/doris/kafka/connector/metrics/MetricsJmxReporter.java	18	2	3
public void commit() in src/main/java/org/apache/doris/kafka/connector/writer/StreamLoadWriter.java	18	2	1
public String toString() in src/main/java/org/apache/doris/kafka/connector/model/doris/Field.java	17	1	0
private static String parseResponse() in src/main/java/org/apache/doris/kafka/connector/service/RestService.java	17	3	2
public static Schema getSchema() in src/main/java/org/apache/doris/kafka/connector/service/RestService.java	17	2	4