apache / pulsar - Conditional 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 19,743 units with 212,135 lines of code in units (67.6% of code).

6 very complex units (1,480 lines of code)
59 complex units (7,784 lines of code)
399 medium complex units (25,833 lines of code)
1,113 simple units (37,760 lines of code)
18,166 very simple units (139,278 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
public void channelRead() in pulsar-common/src/main/java/org/apache/pulsar/common/protocol/PulsarDecoder.java	317	69	2
void processArguments() in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java	217	66	0
public static FunctionDetails convert() in pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java	250	65	2
public Set findBundlesForUnloading() in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/scheduler/TransferShedder.java	339	65	3
public static void doCommonChecks() in pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java	134	62	1
public CompletableFuture closeAsync() in pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java	223	52	0
public static FunctionDetails convert() in pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java	184	50	2
public void run() in pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceTransaction.java	305	48	0
void processArguments() in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSinks.java	142	46	0
public static ExtractedSinkDetails validateAndExtractDetails() in pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java	142	46	4
public static FunctionConfig validateUpdate() in pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/FunctionConfigUtils.java	140	46	2
func file_Function_proto_init() in pulsar-function-go/pb/Function.pb.go	194	45	0
public void run() in pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java	268	44	0
public boolean equals() in pulsar-client-admin-api/src/main/java/org/apache/pulsar/common/policies/data/Policies.java	51	44	1
private CompletableFuture internalSubscribe() in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentTopic.java	156	43	17
protected void handleSubscribe() in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java	234	42	1
protected void handleProducer() in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java	223	42	1
public int filterEntriesForConsumer() in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractBaseDispatcher.java	168	41	9
public static PulsarClientException unwrap() in pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java	88	40	1
private void runProducer() in pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceProducer.java	216	39	7
public static SinkConfig validateUpdate() in pulsar-functions/utils/src/main/java/org/apache/pulsar/functions/utils/SinkConfigUtils.java	127	39	2
public static Throwable wrap() in pulsar-client-api/src/main/java/org/apache/pulsar/client/api/PulsarClientException.java	79	38	2
public static List getGoInstanceCmd() in pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java	141	37	7
public void updateSink() in pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SinksImpl.java	150	37	9
void internalTrimLedgers() in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedLedgerImpl.java	180	36	2
public CompletableFuture connectionOpened() in pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java	164	35	1
public void updateSource() in pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SourcesImpl.java	147	35	9
public void updateFunction() in pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.java	149	35	9
private Response generateResponseWithEntry() in pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java	136	35	2
void processArguments() in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdSources.java	104	34	0
static Object jsonAsConnectData() in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema/KafkaConnectData.java	102	34	2
public static List getCmd() in pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/RuntimeUtils.java	191	34	22
public Set findBundlesToSplit() in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/strategy/DefaultNamespaceBundleSplitStrategyImpl.java	200	34	2
public void sendAsync() in pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java	122	33	2
public static Object castToKafkaSchema() in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema/KafkaConnectData.java	91	33	2
def main() in pulsar-functions/instance/src/main/python/python_instance_main.py	137	33	0
void messageReceived() in pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java	112	32	3
private void mergeArgs() in pulsar-client-tools/src/main/java/org/apache/pulsar/admin/cli/CmdFunctions.java	47	31	0
private void recoverProcessOpSendMsgFrom() in pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java	113	31	4
public Pair extractIdAndDocument() in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchSink.java	112	31	1
public void start() in pulsar-broker/src/main/java/org/apache/pulsar/broker/PulsarService.java	195	31	0
protected void monitorOwnerships() in pulsar-broker/src/main/java/org/apache/pulsar/broker/loadbalance/extensions/channel/ServiceUnitStateChannelImpl.java	115	31	1
public void runPerformanceTest() in pulsar-testclient/src/main/java/org/apache/pulsar/proxy/socket/client/PerformanceClient.java	154	30	0
public void asyncDelete() in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/ManagedCursorImpl.java	132	30	3
public void validate() in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch/ElasticSearchConfig.java	48	30	0
public void registerSink() in pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SinksImpl.java	139	30	8
public CompletableFuture allowTopicOperationAsync() in pulsar-broker-common/src/main/java/org/apache/pulsar/broker/authorization/PulsarAuthorizationProvider.java	53	29	4
public void registerSource() in pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/SourcesImpl.java	136	29	8
public synchronized void readMoreEntries() in pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumersClassic.java	107	29	0
static int internalEstimateEntryCountByBytesSize() in managed-ledger/src/main/java/org/apache/bookkeeper/mledger/impl/EntryCountEstimator.java	81	28	7