apache / cassandra-analytics

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 3,849 units with 31,826 lines of code in units (66.7% of code).

3 very long units (365 lines of code)
30 long units (1,903 lines of code)
238 medium size units (7,027 lines of code)
566 small units (8,116 lines of code)
3,012 very small units (14,415 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
public SSTableReader() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/SSTableReader.java	160	21	10
public static Mutation makeMutation() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/bridge/CdcBridgeImplementation.java	103	17	4
public boolean next() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/AbstractStreamScanner.java	102	20	0
private void readSection() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/db/commitlog/BufferingCommitLogReader.java	91	15	2
private static Schema convertLiteralType() in cassandra-four-zero-avro-converter/src/main/java/org/apache/cassandra/cdc/avro/CqlToAvroSchemaConverterImplementation.java	83	22	2
public WriteResult write() in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/RecordWriter.java	78	9	1
public BulkSparkConf() in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/BulkSparkConf.java	74	6	2
static void consumePrimaryIndex() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/IndexReader.java	73	14	8
public static Converter getConverter() in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/SqlToCqlTypeConverter.java	72	29	1
private static Schema schemaFrom() in cassandra-four-zero-avro-converter/src/main/java/org/apache/cassandra/cdc/avro/CqlToAvroSchemaConverterImplementation.java	71	9	2
public IndexReader() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/IndexReader.java	70	7	5
public static boolean equals() in cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/ComparisonUtils.java	70	23	2
protected void loadFromResource() in cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/schemastore/LocalTableSchemaStore.java	69	9	0
public BufferingCommitLogReader() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/db/commitlog/BufferingCommitLogReader.java	68	8	9
public static Object toAvro() in cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/avro/AvroDataUtils.java	68	11	2
static Map deserializeStatsMetadata() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/ReaderUtils.java	66	8	3
private static Pair updateSchema() in cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/reader/SchemaBuilder.java	62	8	9
public boolean next() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/cdc/scanner/CdcSortedStreamScanner.java	62	13	0
private void decompressChunk() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/CompressedRawInputStream.java	60	9	2
public List contains() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/bridge/CassandraBridgeImplementation.java	59	8	5
public AbstractCluster initializeCluster() in cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/distributed/impl/CassandraCluster.java	59	7	2
static ByteBuffer encodeCellName() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/ReaderUtils.java	57	13	4
public void processEvent() in cassandra-analytics-cdc-codec/src/main/java/org/apache/cassandra/cdc/kafka/KafkaPublisher.java	57	7	1
public void readPartitionKeys() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/bridge/CassandraBridgeImplementation.java	56	4	8
private void validateType() in cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/reader/SchemaBuilder.java	55	14	1
private void persist() in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/CassandraBulkSourceRelation.java	55	4	2
private void rawAddRow() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/io/sstable/SSTableTombstoneWriter.java	55	9	1
public CdcStreamScanner build() in cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/scanner/CdcScannerBuilder.java	55	3	0
static InstanceMetadata buildInstanceMetadata() in cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/sidecar/testing/SharedClusterIntegrationTestBase.java	54	2	8
protected CassandraDataLayer() in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/CassandraDataLayer.java	51	2	22
public SSTablesSupplier sstables() in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/PartitionedDataLayer.java	51	5	3
public StorageClient() in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/cloudstorage/StorageClient.java	51	3	2
public SidecarConfiguration sidecarConfiguration() in cassandra-analytics-integration-framework/src/main/java/org/apache/cassandra/sidecar/testing/SharedClusterIntegrationTestBase.java	51	3	0
public SSTableTombstoneWriter build() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/io/sstable/SSTableTombstoneWriter.java	50	8	0
public boolean hasNext() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/spark/reader/SSTableReader.java	50	10	0
private static void setupTableAndUdt() in cassandra-four-zero-types/src/main/java/org/apache/cassandra/spark/reader/SchemaBuilder.java	49	7	4
private void readMutationInternal() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/db/commitlog/BufferingCommitLogReader.java	49	4	3
public MicroBatchIterator() in cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/MicroBatchIterator.java	49	6	10
public static void updateCdcSchema() in cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java	48	6	4
private void readObject() in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/CassandraDataLayer.java	48	3	1
private void readCommitLogSegment() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/db/commitlog/BufferingCommitLogReader.java	48	8	0
private void addColumn() in cassandra-four-zero-bridge/src/main/java/org/apache/cassandra/cdc/msg/FourZeroCdcEventBuilder.java	48	7	2
public void streamCdcCommitLogSegment() in cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarCdcClient.java	48	1	4
public void validate() in cassandra-analytics-sidecar-client/src/main/java/org/apache/cassandra/spark/validation/KeyStoreValidation.java	47	11	0
public void start() in cassandra-analytics-core-example/src/main/java/org/apache/cassandra/spark/example/AbstractCassandraJob.java	47	7	1
public CdcScannerBuilder() in cassandra-analytics-cdc/src/main/java/org/apache/cassandra/cdc/scanner/CdcScannerBuilder.java	47	2	10
public int compare() in cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/utils/ComparisonUtils.java	46	16	2
protected T validate() in cassandra-analytics-common/src/main/java/org/apache/cassandra/secrets/SslConfig.java	46	13	0
protected void persistToCassandra() in cassandra-analytics-cdc-sidecar/src/main/java/org/apache/cassandra/cdc/sidecar/SidecarStatePersister.java	46	7	1
private List collectSSTableList() in cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/data/CassandraDataLayer.java	45	6	3