apache / cassandra-spark-connector

Intro

Unit size measurements show the distribution of size of units of code (methods, functions...).
Units are classified in four categories based on their size (lines of code): 1-20 (small units), 20-50 (medium size units), 51-100 (long units), 101+ (very long units).
You should aim at keeping units small (< 20 lines). Long units may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.

Learn more...

Unit Size Overall

There are 1,207 units with 11,027 lines of code in units (33.7% of code).

1 very long units (138 lines of code)
9 long units (544 lines of code)
91 medium size units (2,555 lines of code)
214 small units (3,069 lines of code)
892 very small units (4,721 lines of code)

Legend:

101+

51-100

21-50

11-20

1-10

Unit Size per Extension

101+

51-100

21-50

11-20

1-10

Unit Size per Logical Component

primary logical decomposition

101+

51-100

21-50

11-20

1-10

Alternative Visuals

3D view of all units

Longest Units

Top 50 longest units

Unit	# lines	McCabe index	# params
def apply[T : TypeTag : ColumnMapper]() in driver/src/main/scala/com/datastax/spark/connector/mapper/MappedToGettableDataConverter.scala	138	35	3
override def create() in test-support/src/main/scala/com/datastax/spark/connector/ccm/mode/StandardModeExecutor.scala	73	18	1
override def createTable() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraCatalog.scala	72	18	5
override protected def doExecute() in connector/src/main/scala/org/apache/spark/sql/cassandra/execution/CassandraDirectJoinExec.scala	62	4	0
def connectorConfigBuilder() in connector/src/main/scala/com/datastax/spark/connector/cql/CassandraConnectionFactory.scala	60	7	2
def convertToSolrQuery() in connector/src/main/scala/org/apache/spark/sql/cassandra/SolrPredicateRules.scala	60	9	5
private def forCollectionType() in driver/src/main/scala/com/datastax/spark/connector/types/TypeConverter.scala	56	29	2
def fromScalaType() in driver/src/main/scala/com/datastax/spark/connector/types/ColumnType.scala	55	39	2
def replaceMetadata() in connector/src/main/scala/org/apache/spark/sql/cassandra/CassandraMetadataFunctions.scala	54	13	2
def getLatestException() in connector/src/main/scala/com/datastax/spark/connector/writer/AsyncExecutor.scala	52	7	0
def fromSparkConf() in connector/src/main/scala/com/datastax/spark/connector/writer/WriteConf.scala	50	6	1
override def compute() in connector/src/main/scala/com/datastax/spark/connector/rdd/CassandraMergeJoinRDD.scala	49	5	2
def createCassandraTableEx() in connector/src/main/scala/com/datastax/spark/connector/DatasetFunctions.scala	48	2	5
override def alterTable() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraCatalog.scala	47	12	2
override def compute() in connector/src/main/scala/com/datastax/spark/connector/rdd/CassandraCoGroupedRDD.scala	47	6	2
def dataFrame() in connector/src/it/scala/com/datastax/spark/connector/sql/CassandraDataFrameDateBehaviors.scala	46	1	1
private[cassandra] def apply() in connector/src/main/scala/org/apache/spark/sql/cassandra/SolrPredicateRules.scala	42	6	5
private def checkCollectionBehaviors() in connector/src/main/scala/com/datastax/spark/connector/writer/TableWriter.scala	40	8	2
def execute() in test-support/src/main/scala/com/datastax/spark/connector/ccm/CcmBridge.scala	40	7	1
private[rdd] def fetchIterator() in connector/src/main/scala/com/datastax/spark/connector/rdd/CassandraLeftJoinRDD.scala	36	5	5
override def apply() in connector/src/main/scala/org/apache/spark/sql/cassandra/execution/CassandraDirectJoinStrategy.scala	36	7	1
private[connector] def withPartitioner[K, V, T <: ConnectorToken[V]]() in connector/src/main/scala/com/datastax/spark/connector/rdd/CassandraTableScanRDD.scala	35	6	1
def getSolrIndexedColumnsFromSolrXML() in connector/src/main/scala/org/apache/spark/sql/cassandra/SolrPredicateRules.scala	35	5	2
private def getIpBasedContactInfoFromSparkConf() in connector/src/main/scala/com/datastax/spark/connector/cql/CassandraConnectorConf.scala	34	2	1
def fromSparkConf() in connector/src/main/scala/com/datastax/spark/connector/cql/CassandraConnectorConf.scala	34	1	1
def getJoinQueryString() in connector/src/main/scala/com/datastax/spark/connector/datasource/JoinHelper.scala	34	9	3
def getPartitionGenerator() in connector/src/main/scala/com/datastax/spark/connector/datasource/ScanHelper.scala	34	6	6
public CassandraJavaPairRDD joinWithCassandraTable() in connector/src/main/java/com/datastax/spark/connector/japi/RDDJavaFunctions.java	34	1	6
def consolidateConfs() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraSourceUtil.scala	33	2	7
def catalystDataType() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraSourceUtil.scala	33	11	2
private[rdd] def fetchIterator() in connector/src/main/scala/com/datastax/spark/connector/rdd/CassandraJoinRDD.scala	33	3	5
override def read() in connector/src/main/scala/com/datastax/spark/connector/rdd/reader/FunctionBasedRowReader.scala	32	1	2
override def columnMapForReading() in driver/src/main/scala/com/datastax/spark/connector/mapper/ReflectionColumnMapper.scala	31	4	2
protected def checkValidJoin() in connector/src/main/scala/com/datastax/spark/connector/rdd/AbstractCassandraJoin.scala	31	2	0
private def pushFiltersToSpark() in connector/src/main/scala/org/apache/spark/sql/cassandra/InClausePredicateRules.scala	31	3	2
override def columnMapForWriting() in driver/src/main/scala/com/datastax/spark/connector/mapper/TupleColumnMapper.scala	30	11	2
private def rangeToCql() in connector/src/main/scala/com/datastax/spark/connector/rdd/partitioner/CassandraPartitionGenerator.scala	30	4	1
override def read() in connector/src/main/scala/com/datastax/spark/connector/rdd/reader/FunctionBasedRowReader.scala	30	1	2
override def getPreferredLocations() in connector/src/main/scala/com/datastax/spark/connector/rdd/CassandraTableScanRDD.scala	30	3	1
def reorderPlan() in connector/src/main/scala/org/apache/spark/sql/cassandra/execution/CassandraDirectJoinStrategy.scala	30	12	3
def fudgeSizeEstimatesTable() in connector/src/it/scala/com/datastax/spark/connector/rdd/CassandraRDDSpec.scala	30	3	2
override def newTable() in driver/src/main/scala/com/datastax/spark/connector/mapper/DefaultColumnMapper.scala	29	5	3
override def onReadTimeout() in driver/src/main/scala/com/datastax/spark/connector/cql/MultipleRetryPolicy.scala	29	1	6
def sparkSqlToJavaDriverType() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraSourceUtil.scala	29	19	2
override def alterNamespace() in connector/src/main/scala/com/datastax/spark/connector/datasource/CassandraCatalog.scala	29	7	2
private def structTypeDecoder() in connector/src/main/scala/com/datastax/spark/connector/datasource/UnsafeRowReaderFactory.scala	29	9	1
def getMarkDown() in connector/src/main/scala/com/datastax/spark/connector/util/RefBuilder.scala	28	9	0
override def read() in connector/src/main/scala/com/datastax/spark/connector/rdd/reader/FunctionBasedRowReader.scala	28	1	2
implicit def cqlVectorConverter[T <: Number : TypeConverter]() in driver/src/main/scala/com/datastax/spark/connector/types/TypeConverter.scala	27	9	1
override def invoke() in connector/src/main/scala/com/datastax/spark/connector/cql/SessionProxy.scala	27	8	3