apache / cassandra-spark-connector - 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 1,207 units with 11,027 lines of code in units (33.7% of code).

0 very complex units (0 lines of code)
3 complex units (249 lines of code)
15 medium complex units (517 lines of code)
50 simple units (1,150 lines of code)
1,139 very simple units (9,111 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
def fromScalaType() in driver/src/main/scala/com/datastax/spark/connector/types/ColumnType.scala	55	39	2
def apply[T : TypeTag : ColumnMapper]() in driver/src/main/scala/com/datastax/spark/connector/mapper/MappedToGettableDataConverter.scala	138	35	3
private def forCollectionType() in driver/src/main/scala/com/datastax/spark/connector/types/TypeConverter.scala	56	29	2
def sparkSqlToJavaDriverType() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraSourceUtil.scala	29	19	2
def isConvertibleToSolr() in connector/src/main/scala/org/apache/spark/sql/cassandra/SolrPredicateRules.scala	22	19	2
override def createTable() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraCatalog.scala	72	18	5
def toUnsafeSqlType() in connector/src/main/scala/org/apache/spark/sql/cassandra/CassandraSQLRow.scala	23	18	1
override def create() in test-support/src/main/scala/com/datastax/spark/connector/ccm/mode/StandardModeExecutor.scala	73	18	1
def getSuggestions() in driver/src/main/scala/com/datastax/spark/connector/util/NameTools.scala	25	17	3
def convertToSolrFilter() in connector/src/main/scala/org/apache/spark/sql/cassandra/SolrPredicateRules.scala	25	17	1
private def orderingFor() in driver/src/main/scala/com/datastax/spark/connector/types/TypeConverter.scala	18	16	1
def containsPartitionKey() in connector/src/main/scala/com/datastax/spark/connector/datasource/ScanHelper.scala	24	13	2
def replaceMetadata() in connector/src/main/scala/org/apache/spark/sql/cassandra/CassandraMetadataFunctions.scala	54	13	2
override def alterTable() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraCatalog.scala	47	12	2
def reorderPlan() in connector/src/main/scala/org/apache/spark/sql/cassandra/execution/CassandraDirectJoinStrategy.scala	30	12	3
override def columnMapForWriting() in driver/src/main/scala/com/datastax/spark/connector/mapper/TupleColumnMapper.scala	30	11	2
private def makeSerializable() in connector/src/main/scala/com/datastax/spark/connector/writer/ObjectSizeEstimator.scala	12	11	1
def catalystDataType() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraSourceUtil.scala	33	11	2
def converterToCassandra() in driver/src/main/scala/com/datastax/spark/connector/types/ColumnType.scala	17	10	1
def contains() in connector/src/main/scala/com/datastax/spark/connector/rdd/partitioner/dht/TokenRange.scala	6	10	1
private[connector] def convert() in driver/src/main/scala/com/datastax/spark/connector/GettableData.scala	11	9	1
def sortNodesByStatusAndProximity() in driver/src/main/scala/com/datastax/spark/connector/cql/LocalNodeFirstLoadBalancingPolicy.scala	11	9	2
implicit def cqlVectorConverter[T <: Number : TypeConverter]() in driver/src/main/scala/com/datastax/spark/connector/types/TypeConverter.scala	27	9	1
def getErrorString() in driver/src/main/scala/com/datastax/spark/connector/util/NameTools.scala	8	9	3
def getMarkDown() in connector/src/main/scala/com/datastax/spark/connector/util/RefBuilder.scala	28	9	0
def getJoinQueryString() in connector/src/main/scala/com/datastax/spark/connector/datasource/JoinHelper.scala	34	9	3
private def structTypeDecoder() in connector/src/main/scala/com/datastax/spark/connector/datasource/UnsafeRowReaderFactory.scala	29	9	1
def convertToSolrQuery() in connector/src/main/scala/org/apache/spark/sql/cassandra/SolrPredicateRules.scala	60	9	5
def catalystDataType() in connector/src/main/scala/org/apache/spark/sql/cassandra/DataTypeConverter.scala	24	9	2
private def converter[U : TypeTag]() in driver/src/main/scala/com/datastax/spark/connector/mapper/GettableDataToMappedTypeConverter.scala	26	8	1
override def invoke() in connector/src/main/scala/com/datastax/spark/connector/cql/SessionProxy.scala	27	8	3
final def release() in connector/src/main/scala/com/datastax/spark/connector/cql/RefCountMap.scala	16	8	2
private def checkCollectionBehaviors() in connector/src/main/scala/com/datastax/spark/connector/writer/TableWriter.scala	40	8	2
def checkColumnsExistence() in connector/src/main/scala/com/datastax/spark/connector/datasource/ScanHelper.scala	24	8	2
private def filterToCqlAndValue() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraScanBuilder.scala	14	8	2
override def columnName() in connector/src/main/scala/org/apache/spark/sql/cassandra/PredicateOps.scala	10	8	1
override def isSingleColumnPredicate() in connector/src/main/scala/org/apache/spark/sql/cassandra/PredicateOps.scala	9	8	1
def findUselessIsNotNulls() in connector/src/main/scala/org/apache/spark/sql/cassandra/SolrPredicateRules.scala	17	8	2
override def newInstance() in driver/src/main/scala/com/datastax/spark/connector/types/TupleType.scala	21	7	1
def connectorConfigBuilder() in connector/src/main/scala/com/datastax/spark/connector/cql/CassandraConnectionFactory.scala	60	7	2
def getLatestException() in connector/src/main/scala/com/datastax/spark/connector/writer/AsyncExecutor.scala	52	7	0
override def alterNamespace() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraCatalog.scala	29	7	2
def joinColumnNames() in connector/src/main/scala/com/datastax/spark/connector/datasource/JoinHelper.scala	17	7	2
override def pushedFilters() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraScanBuilder.scala	18	7	0
private def toCqlValue() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraScanBuilder.scala	17	7	3
private def pushDownPredicates() in connector/src/main/scala/org/apache/spark/sql/cassandra/DsePredicateRules.scala	19	7	2
override def apply() in connector/src/main/scala/org/apache/spark/sql/cassandra/execution/CassandraDirectJoinStrategy.scala	36	7	1
def execute() in test-support/src/main/scala/com/datastax/spark/connector/ccm/CcmBridge.scala	40	7	1
def forType() in driver/src/main/scala/com/datastax/spark/connector/types/TypeConverter.scala	12	6	2
private def findTimeZoneIndex() in driver/src/main/scala/com/datastax/spark/connector/types/TimestampParser.scala	11	6	1