apache / rocketmq-externalsConditional 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 988 units with 8,359 lines of code in units (54.5% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
13 medium complex units (664 lines of code)
55 simple units (1,466 lines of code)
920 very simple units (6,229 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 def computePullFromWhere() in rocketmq-spark/src/main/scala/org/apache/spark/streaming/MQPullInputDStream.scala	78	19	1
public static ColumnParser getColumnParser() in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/ColumnParser.java	32	19	3
private void properties2Object() in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/Config.java	38	18	2
private void properties2Object() in rocketmq-hbase/rocketmq-hbase-source/src/main/java/org/apache/rocketmq/hbase/source/Config.java	38	18	2
public static JmsBaseMessage convert2JMSMessage() in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/util/MessageConverter.java	62	17	1
public static Message getMessage() in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/common/util/MessageUtil.java	49	15	1
private def validateBatchOptions() in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQSourceProvider.scala	33	14	2
def main() in dev/merge_rocketmq_pr.py	67	14	0
private void doProcess() in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/binlog/EventProcessor.java	36	13	0
def resolve_jira_issue() in dev/merge_rocketmq_pr.py	47	13	3
public Status process() in rocketmq-flume/rocketmq-flume-sink/src/main/java/org/apache/rocketmq/flume/ng/sink/RocketMQSink.java	61	13	0
private def maxMessagesPerPartition() in rocketmq-spark/src/main/scala/org/apache/spark/streaming/MQPullInputDStream.scala	43	12	3
override def getBatch() in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQSource.scala	80	12	2
def fetchSpecificOffsets() in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQOffsetReader.scala	34	10	3
private def fetchData() in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/CachedRocketMQConsumer.scala	40	10	4
override def compute() in rocketmq-spark/src/main/scala/org/apache/spark/streaming/MQPullInputDStream.scala	44	9	1
func() in rocketmq-knative/source/pkg/controller/testing/table.go	34	9	1
func() in rocketmq-knative/source/pkg/controller/sdk/reconciler.go	35	9	1
private boolean match() in rocketmq-iot-bridge/src/main/java/org/apache/rocketmq/iot/storage/subscription/impl/InMemorySubscriptionStore.java	20	8	2
public boolean equals() in rocketmq-spark/src/main/java/org/apache/rocketmq/spark/TopicQueueId.java	25	8	1
def validateQuery() in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQWriter.scala	33	8	4
public int readBytes() in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/message/JmsBytesMessage.java	27	8	2
public void initBeginPosition() in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/position/BinlogPositionManager.java	15	8	0
public Object getValue() in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/column/StringColumnParser.java	21	8	1
func GetSinkURI() in rocketmq-knative/source/pkg/controller/sinks/sinks.go	28	8	4
func() in rocketmq-knative/source/pkg/controller/testing/table.go	15	8	1
func() in rocketmq-knative/source/pkg/controller/sdk/reconciler.go	32	8	1
func NewReflectedFinalizersAccessor() in rocketmq-knative/source/pkg/controller/sdk/finalizers_accessor.go	23	8	1
private def consumer() in rocketmq-spark/src/main/scala/org/apache/spark/streaming/MQPullInputDStream.scala	32	7	0
protected def latestOffsets() in rocketmq-spark/src/main/scala/org/apache/spark/streaming/MQPullInputDStream.scala	34	7	0
def getRocketMQOffsetRangeLimit() in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQSourceProvider.scala	13	7	4
override def equals() in rocketmq-spark/src/main/scala/org/apache/rocketmq/spark/OffsetRange.scala	9	7	1
public static Message convert2RMQMessage() in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/util/MessageConverter.java	29	7	1
public void send() in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/JmsBaseMessageProducer.java	26	7	2
public JmsBaseMessageConsumer() in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/JmsBaseMessageConsumer.java	34	7	3
public void copyMetaData() in rocketmq-jms/core/src/main/java/org/apache/rocketmq/jms/domain/message/JmsBaseMessage.java	16	7	1
public void load() in rocketmq-mysql/src/main/java/org/apache/rocketmq/mysql/schema/Schema.java	31	7	0
func main() in rocketmq-knative/source/cmd/controller/main.go	30	7	0
func() in rocketmq-knative/source/pkg/controller/sdk/reconciler.go	30	7	1
func() in rocketmq-knative/source/pkg/reconciler/eventtype/eventtype.go	24	7	1
public void start() in rocketmq-logstash-integration/rocketmq-logstash-input/src/main/java/org/apache/rocketmq/logstashplugin/input/RocketMQ.java	25	7	1
private void createAndStartConsumer() in rocketmq-logstash-integration/rocketmq-logstash-input/src/main/java/org/apache/rocketmq/logstashplugin/input/RocketMQ.java	26	7	0
def merge_pr() in dev/merge_rocketmq_pr.py	51	7	5
def standardize_jira_ref() in dev/merge_rocketmq_pr.py	19	7	1
public Boolean getBool() in rocketmq-redis/src/main/java/org/apache/rocketmq/redis/replicator/conf/Configure.java	10	7	3
public void onStart() in rocketmq-spark/src/main/java/org/apache/rocketmq/spark/streaming/RocketMQReceiver.java	42	6	0
protected def commitAll() in rocketmq-spark/src/main/scala/org/apache/spark/streaming/MQPullInputDStream.scala	20	6	0
private def withRetries() in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/RocketMQOffsetReader.scala	24	6	2
def partitionOffsets() in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/JsonUtils.scala	15	6	1
def get() in rocketmq-spark/src/main/scala/org/apache/spark/sql/rocketmq/CachedRocketMQConsumer.scala	30	6	4