apache / rocketmq-eventbridgeConditional 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 937 units with 7,576 lines of code in units (48.3% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
16 medium complex units (687 lines of code)
41 simple units (950 lines of code)
880 very simple units (5,939 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 checkOAuthParameters() in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java	39	20	1
public static void properties2Object() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/FileAndPropertyUtil.java	38	18	2
public void serialize() in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/format/BatchedCloudEventSerializer.java	63	17	3
public void run() in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java	78	16	0
private void checkConfig() in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/HttpEventConverter.java	40	16	4
public static PatternEvaluator build() in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternEvaluatorBuilder.java	77	16	1
private boolean isEqualsComponents() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/TargetRunnerConfig.java	37	15	2
public static List pluginUrls() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/PluginUtils.java	73	14	1
private AuthParameters updateSecretData() in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java	46	13	4
public void resetOffset() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/trigger/TriggerTaskContext.java	28	12	1
public PatternCondition build() in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternConditionBuilder.java	34	12	1
long nextPullOffset() in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java	42	11	1
public PatternCondition build() in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternConditionBuilder.java	31	11	1
public boolean match() in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternCondition.java	23	11	1
private void checkApiKeyAuthParameters() in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java	19	11	1
private void checkBasicAuthParameters() in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java	19	11	1
public List parseElementFromConnectRecord() in supports/connect-eventbridge-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge/ConnectRecordJsonPathExtract.java	32	10	1
public void pause() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/trigger/TriggerTaskContext.java	25	10	1
public void resume() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/trigger/TriggerTaskContext.java	25	10	1
private void submitPullTask() in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java	34	10	3
private void checkNetworkType() in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java	26	10	1
public void resetOffset() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/trigger/TriggerTaskContext.java	20	9	2
public boolean testEventPattern() in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternEvaluator.java	36	9	1
private void checkIp() in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source/HTTPEventSourceService.java	18	9	2
private void checkReferer() in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/source/HTTPEventSourceService.java	21	9	2
public static Transform buildTransform() in supports/connect-eventbridge-transform/src/main/java/org/apache/rocketmq/connect/transform/eventbridge/EventBridgeTransformBuilder.java	20	8	1
public static Transform buildTransform() in common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/TransformBuilder.java	21	8	1
public void updateConnection() in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java	24	8	2
protected void checkNameValidate() in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/AbstractResourceService.java	20	8	7
public void run() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java	47	7	0
private void refreshRunnerContext() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java	31	7	2
private void initMqProperties() in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java	36	7	0
public boolean match() in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternEntry.java	19	7	1
public boolean match() in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/NumericOperators.java	19	7	2
public Data parse() in common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/StringSubstitutorTemplate.java	28	7	1
public static boolean isNetSegment() in common/src/main/java/org/apache/rocketmq/eventbridge/tools/NetUtil.java	16	7	1
private void updateClientByKms() in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java	22	7	4
public EventSourceClass checkEventSourceAPIParams() in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/classes/EventSourceClassService.java	21	7	2
public EventTargetClass checkEventSourceAPIParams() in domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/classes/EventTargetClassService.java	21	7	2
public void run() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java	27	6	0
public boolean equals() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/entity/SubscribeRunnerKeys.java	6	6	1
public synchronized Class loadClass() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/plugin/PluginClassLoader.java	22	6	2
public Set getLatestTargetRunnerConfig() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java	18	6	0
private int calcDelaySec() in adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/error/ErrorHandler.java	17	6	2
private static int putIfPresent() in adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/api/RocketMQEventDataAPIImpl.java	20	6	3
private HttpEventData getHttpEventData() in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/converter/HttpEventConverter.java	41	6	5
private ConnectionResponse dataMasking() in adapter/api/src/main/java/org/apache/rocketmq/eventbridge/adapter/api/controller/ConnectionController.java	26	6	1
public PatternCondition build() in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternConditionBuilder.java	21	6	1
public static String getTargetElementOfFilterPattern() in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternEvaluatorBuilder.java	23	6	2
private static PatternEntry parsePatternEntry() in common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/PatternEvaluatorBuilder.java	20	6	3