azure / azure-event-hubs-spark - 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 209 units with 2,153 lines of code in units (59.6% of code).

0 very complex units (0 lines of code)
0 complex units (0 lines of code)
5 medium complex units (348 lines of code)
8 simple units (265 lines of code)
196 very simple units (1,540 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 parseConnectionString() in core/src/main/scala/org/apache/spark/eventhubs/ConnectionStringBuilder.scala	79	24	1
def toInternalRow() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSourceProvider.scala	64	19	1
override def getBatch() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala	82	16	2
override def translate() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	81	12	3
final def retryScala[T]() in core/src/main/scala/org/apache/spark/eventhubs/utils/RetryUtils.scala	42	11	5
private def rateLimit() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala	49	8	7
private def checkCursor() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	52	8	1
private[eventhubs] override def receive() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	42	8	4
private def parseLogVersion() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala	26	7	2
override def equals() in core/src/main/scala/org/apache/spark/eventhubs/EventPosition.scala	10	6	1
private def receive() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	57	6	2
override def send() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	21	6	5
override def equals() in core/src/main/scala/org/apache/spark/eventhubs/rdd/OffsetRange.scala	8	6	1
private def closeInner() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsForeachWriter.scala	21	5	1
def partitionSeqNos() in core/src/main/scala/org/apache/spark/sql/eventhubs/JsonUtils.scala	16	5	1
private[eventhubs] def set[T]() in core/src/main/scala/org/apache/spark/eventhubs/EventHubsConf.scala	14	5	2
def partitionsPerformancePercentage() in core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala	38	5	0
def partitions() in core/src/main/scala/org/apache/spark/sql/eventhubs/JsonUtils.scala	17	4	1
def close() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriteTask.scala	22	4	0
private def toProperties() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriteTask.scala	14	4	1
def getPartitionSeqNos() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSourceOffset.scala	9	4	1
private def createRpcEndpoint() in core/src/main/scala/org/apache/spark/eventhubs/EventHubsUtils.scala	19	4	0
def updatePerformancePercentage() in core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala	8	4	2
override def allBoundedSeqNos: Map[PartitionId,() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	16	4	2
private def latestSeqNoF() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	13	4	1
override def equals() in core/src/main/scala/org/apache/spark/eventhubs/NameAndPartition.scala	6	4	1
override def count: Long = offsetRanges.map() in core/src/main/scala/org/apache/spark/eventhubs/rdd/EventHubsRDD.scala	25	4	1
override def compute() in core/src/main/scala/org/apache/spark/streaming/eventhubs/EventHubsDirectDStream.scala	27	4	1
override def deserialize() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala	17	3	1
private def adjustStartingOffset() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala	15	3	2
override def createRelation() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSourceProvider.scala	27	3	5
private def validateQuery() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsWriter.scala	14	3	3
def close() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsForeachWriter.scala	10	3	1
def setEndpoint() in core/src/main/scala/org/apache/spark/eventhubs/ConnectionStringBuilder.scala	11	3	2
private[utils] def send() in core/src/main/scala/org/apache/spark/eventhubs/utils/SimulatedEventHubs.scala	16	3	4
override def equals() in core/src/main/scala/org/apache/spark/eventhubs/EventHubsConf.scala	5	3	1
def setPrefetchCount() in core/src/main/scala/org/apache/spark/eventhubs/EventHubsConf.scala	7	3	1
def addorUpdateBatch() in core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala	27	3	2
def updatePartitionPerformance() in core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala	19	3	4
def matchSeqNoAndBatchSize() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	6	3	2
private def receiveOne() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	20	3	2
private def awaitReceiveMessage[T]() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	13	3	2
private def sendPartitionPerformanceToDriver() in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala	13	3	1
override def createPartitionSender() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	13	3	1
private def earliestSeqNoF() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	7	3	1
override def close() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	14	3	0
private def cleanup() in core/src/main/scala/org/apache/spark/eventhubs/client/EventHubsClient.scala	11	3	0
private def errBeginAfterEnd() in core/src/main/scala/org/apache/spark/eventhubs/rdd/EventHubsRDD.scala	28	3	1
override def stop() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala	9	2	0
private def compare() in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsSource.scala	7	2	2