apache / streams - 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 2,403 units with 21,137 lines of code in units (41.2% of code).

0 very complex units (0 lines of code)
5 complex units (409 lines of code)
40 medium complex units (1,956 lines of code)
123 simple units (3,315 lines of code)
2,235 very simple units (15,457 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 unwindLink() in streams-contrib/streams-processor-urls/src/main/java/org/apache/streams/urls/LinkResolver.java	112	44	1
public static StringJoiner toStringJoiner() in streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/search/SearchUtil.java	96	31	1
public void write() in streams-contrib/streams-persist-riak/src/main/java/org/apache/streams/riak/http/RiakHttpPersistWriter.java	85	27	1
public ObjectNode resolveProperties() in streams-util/src/main/java/org/apache/streams/util/schema/SchemaStoreImpl.java	58	27	3
public ObjectNode resolveItems() in streams-util/src/main/java/org/apache/streams/util/schema/SchemaStoreImpl.java	58	27	3
private StringBuilder appendPropertiesNode() in streams-plugins/streams-plugin-cassandra/src/main/java/org/apache/streams/plugins/cassandra/StreamsCassandraResourceGenerator.java	69	25	4
private StringBuilder appendPropertiesNode() in streams-plugins/streams-plugin-elasticsearch/src/main/java/org/apache/streams/plugins/elasticsearch/StreamsElasticsearchResourceGenerator.java	69	24	4
public void write() in streams-contrib/streams-persist-riak/src/main/java/org/apache/streams/riak/binary/RiakBinaryPersistWriter.java	75	24	1
public int compare() in streams-util/src/main/java/org/apache/streams/util/schema/SchemaStoreImpl.java	67	24	2
public T detectConfiguration() in streams-config/src/main/java/org/apache/streams/config/ComponentConfigurator.java	74	23	2
protected void collectActivityData() in streams-contrib/streams-provider-google/google-gplus/src/main/java/org/apache/streams/gplus/provider/GPlusUserActivityCollector.java	52	22	0
public int compare() in streams-verbs/src/main/java/org/apache/streams/verbs/ObjectCombinationGenericOrdering.java	25	19	2
public int compare() in streams-verbs/src/main/java/org/apache/streams/verbs/ObjectCombinationSpecificOrdering.java	25	19	2
protected StringBuilder appendArrayItems() in streams-plugins/streams-plugin-cassandra/src/main/java/org/apache/streams/plugins/cassandra/StreamsCassandraResourceGenerator.java	52	19	5
protected StringBuilder appendArrayItems() in streams-plugins/streams-plugin-elasticsearch/src/main/java/org/apache/streams/plugins/elasticsearch/StreamsElasticsearchResourceGenerator.java	52	18	5
protected void getData() in streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/pagefeed/FacebookPageFeedDataCollector.java	36	16	1
void processVideos() in streams-contrib/streams-provider-youtube/src/main/java/org/apache/streams/youtube/provider/YoutubeUserActivityCollector.java	21	16	5
public List process() in streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/processor/FacebookTypeConverter.java	42	15	1
public List process() in streams-contrib/streams-processor-json/src/main/java/org/apache/streams/json/JsonPathFilter.java	67	15	1
public StreamsTask createConnectedTask() in streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/StreamComponent.java	54	15	1
private void shutDownTask() in streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java	38	15	2
public StreamsDatum processLine() in streams-components/streams-converters/src/main/java/org/apache/streams/converter/LineReadWriteUtil.java	45	14	1
public String convertResultToString() in streams-components/streams-converters/src/main/java/org/apache/streams/converter/LineReadWriteUtil.java	54	14	1
public List detectClasses() in streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterDocumentClassifier.java	37	14	1
public void run() in streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java	62	14	0
public synchronized Schema create() in streams-util/src/main/java/org/apache/streams/util/schema/SchemaStoreImpl.java	52	14	1
private StringBuilder appendPropertiesNode() in streams-plugins/streams-plugin-pig/src/main/java/org/apache/streams/plugins/pig/StreamsPigResourceGenerator.java	44	13	4
protected StringBuilder appendRootObject() in streams-plugins/streams-plugin-hbase/src/main/java/org/apache/streams/plugins/hbase/StreamsHbaseResourceGenerator.java	35	13	3
public List process() in streams-contrib/streams-processor-json/src/main/java/org/apache/streams/json/JsonPathExtractor.java	63	13	1
protected Set queueFeedEntries() in streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/provider/RssStreamProviderTask.java	46	13	1
public void run() in streams-contrib/streams-persist-hdfs/src/main/java/org/apache/streams/hdfs/WebHdfsPersistReaderTask.java	58	13	0
public void start() in streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java	47	13	0
public static ObjectNode cleanProperties() in streams-util/src/main/java/org/apache/streams/util/PropertyUtil.java	29	13	2
public T detectCustomConfiguration() in streams-config/src/main/java/org/apache/streams/config/StreamsConfigurator.java	47	12	2
private StringBuilder appendPropertiesNode() in streams-plugins/streams-plugin-hive/src/main/java/org/apache/streams/plugins/hive/StreamsHiveResourceGenerator.java	44	12	4
public List process() in streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/processor/MetadataFromDocumentProcessor.java	48	12	1
protected ObjectNode executePost() in streams-contrib/streams-persist-neo4j/src/main/java/org/apache/streams/neo4j/http/Neo4jHttpPersistWriter.java	39	12	1
private void serializeCategories() in streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/serializer/SyndEntrySerializer.java	36	12	3
public void prepare() in streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java	65	12	1
public Person deserialize() in streams-contrib/streams-provider-google/google-gplus/src/main/java/org/apache/streams/gplus/serializer/util/GPlusPersonDeserializer.java	55	11	2
public StreamsResultSet readAll() in streams-contrib/streams-persist-riak/src/main/java/org/apache/streams/riak/http/RiakHttpPersistReader.java	71	11	0
public RecentMediaResponse selfMediaRecent() in streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/api/Instagram.java	34	11	1
public RecentMediaResponse userMediaRecent() in streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/api/Instagram.java	34	11	1
public void run() in streams-monitoring/src/main/java/org/apache/streams/monitoring/tasks/BroadcastMonitorThread.java	38	11	0
public void run() in streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProcessorTask.java	55	11	0
def sortByAffinityString() in streams-contrib/streams-processor-fullcontact/src/main/scala/org/apache/streams/fullcontact/util/AffinityOrdering.scala	10	10	2
public void run() in streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/provider/RssEventProcessor.java	28	10	0
private void serializeEnclosures() in streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/serializer/SyndEntrySerializer.java	34	10	3
public StreamsTaskCounterBroadcast deserialize() in streams-monitoring/src/main/java/org/apache/streams/jackson/StreamsTaskCounterDeserializer.java	42	10	2
public ThroughputQueueBroadcast deserialize() in streams-monitoring/src/main/java/org/apache/streams/jackson/ThroughputQueueDeserializer.java	41	10	2