apache / rocketmq-schema-registryConditional Complexity

Intro

Conditional complexity (also called cyclomatic complexity) is a term used to measure the complexity of software. The term refers to the number of possible paths through a program function. A higher value ofter means higher maintenance and testing costs (infosecinstitute.com).
Conditional complexity is calculated by counting all conditions in the program that can affect the execution path (e.g. if statement, loops, switches, and/or operators, try and catch blocks...).
Conditional complexity is measured at the unit level (methods, functions...).
Units are classified in four categories based on the measured McCabe index: 1-5 (simple units), 6-10 (medium complex units), 11-25 (complex units), 26+ (very complex units).

Learn more...

Conditional Complexity Overall

There are 605 units with 4,363 lines of code in units (53.5% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
2 medium complex units (84 lines of code)
19 simple units (490 lines of code)
584 very simple units (3,789 lines of code)

Legend:

51+

26-50

11-25

6-10

1-5

Alternative Visuals

3D view of all units

Conditional Complexity per Extension

51+

26-50

11-25

6-10

1-5

Conditional Complexity per Logical Component

primary logical decomposition

51+

26-50

11-25

6-10

1-5

Most Complex Units

Top 50 most complex units

Unit	# lines	McCabe index	# params
private void consumeMessage() in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java	55	13	1
public static String getIp() in common/src/main/java/org/apache/rocketmq/schema/registry/common/utils/CommonUtil.java	29	11	0
private void createStorageTopic() in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java	41	10	0
public void deleteByVersion() in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java	29	9	1
public UpdateSchemaResponse update() in core/src/main/java/org/apache/rocketmq/schema/registry/core/service/SchemaServiceImpl.java	49	9	2
public void updateSchema() in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/handler/SchemaHandler.java	27	9	1
public SchemaRecordInfo getTargetSchema() in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqStorageClientImpl.java	22	8	1
public SchemaRecordInfo getTargetSchema() in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/JdbcStorageService.java	22	8	2
protected void createStorageTables() in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/dialect/GenericDatabaseDialect.java	34	8	0
public T deserialize() in client/src/main/java/org/apache/rocketmq/schema/registry/client/serde/json/JsonDeserializer.java	30	8	2
public T deserialize() in client/src/main/java/org/apache/rocketmq/schema/registry/client/serde/avro/AvroDeserializer.java	36	8	3
public boolean equals() in client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java	13	7	1
public boolean equals() in client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java	13	7	1
public boolean equals() in client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java	13	7	1
public static T sendHttpRequest() in client/src/main/java/org/apache/rocketmq/schema/registry/client/util/HttpUtil.java	42	7	5
static final List findNamesInTemplate() in client/src/main/java/org/apache/rocketmq/schema/registry/client/rest/UrlBuilder.java	19	7	1
public SchemaRecordInfo getBySubject() in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqStorageClientImpl.java	13	6	1
public void deleteByVersion() in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/handler/SchemaHandler.java	18	6	1
public void bindRecord() in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/dialect/GenericDatabaseDialect.java	19	6	4
private IdentifierRules identifierRules() in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/dialect/GenericDatabaseDialect.java	26	6	0
public URI build() in client/src/main/java/org/apache/rocketmq/schema/registry/client/rest/UrlBuilder.java	24	6	1
public SchemaInfo registerSchema() in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java	22	5	1
public void deleteBySubject() in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java	21	5	1
public boolean equals() in example/src/main/java/org/apache/rocketmq/schema/registry/example/serde/Person.java	6	5	1
public static File mkdir() in common/src/main/java/org/apache/rocketmq/schema/registry/common/utils/CommonUtil.java	9	5	1
public void run() in common/src/main/java/org/apache/rocketmq/schema/registry/common/utils/CommonUtil.java	25	5	0
public SchemaRecordInfo getBySubject() in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/JdbcStorageService.java	13	5	2
private synchronized void newConnection() in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/dialect/GenericDatabaseDialect.java	24	5	0
public boolean isConnectionValid() in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/dialect/GenericDatabaseDialect.java	21	5	2
private Schema getReaderSchema() in client/src/main/java/org/apache/rocketmq/schema/registry/client/serde/avro/AvroDeserializer.java	17	5	1
private void startLocalCache() in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java	31	4	0
public SchemaInfo updateSchema() in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java	18	4	1
public List getSubjects() in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java	14	4	2
public void validate() in core/src/main/java/org/apache/rocketmq/schema/registry/core/compatibility/AvroSchemaValidator.java	18	4	2
public Charge build() in example/src/main/java/org/apache/rocketmq/schema/registry/example/serde/Charge.java	10	4	0
private void checkPermission() in common/src/main/java/org/apache/rocketmq/schema/registry/common/auth/DefaultAccessControlServiceImpl.java	11	4	4
public static List listFiles() in common/src/main/java/org/apache/rocketmq/schema/registry/common/utils/CommonUtil.java	9	4	1
public synchronized long nextId() in common/src/main/java/org/apache/rocketmq/schema/registry/common/utils/SnowFlakeIdGenerator.java	19	4	0
static URI toURI() in common/src/main/java/org/apache/rocketmq/schema/registry/common/utils/MemoryJavaFileManager.java	17	4	1
public void loadPlugin() in common/src/main/java/org/apache/rocketmq/schema/registry/common/storage/StorageManager.java	15	4	0
public void entryRemoved() in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/handler/SchemaHandler.java	12	4	1
public void entryUpdated() in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/handler/SchemaHandler.java	9	4	1
public IdentifierRules() in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/common/IdentifierRules.java	9	4	3
public Connection getConnection() in storage-jdbc/src/main/java/org/apache/rocketmq/schema/registry/storage/jdbc/dialect/GenericDatabaseDialect.java	14	4	0
public DeleteSchemeResponse deleteSchema() in client/src/main/java/org/apache/rocketmq/schema/registry/client/CachedSchemaRegistryClient.java	21	4	3
public T deserialize() in client/src/main/java/org/apache/rocketmq/schema/registry/client/serde/avro/ReflectionAvroDeserializer.java	15	4	2
static String encode() in client/src/main/java/org/apache/rocketmq/schema/registry/client/rest/UrlBuilder.java	17	4	2
public ConsumeOrderlyStatus consumeMessage() in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java	12	3	2
public SchemaInfo getSchemaInfoBySubject() in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqClient.java	9	3	1
public static void checkAndPut() in storage-rocketmq/src/main/java/org/apache/rocketmq/schema/registry/storage/rocketmq/RocketmqStorageUtils.java	6	3	3