apache / pekko-persistence-cassandra

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 243 units with 4,724 lines of code in units (58.1% of code).

3 very long units (1,062 lines of code)
8 long units (528 lines of code)
48 medium size units (1,537 lines of code)
57 small units (821 lines of code)
127 very small units (776 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
override def shape = SourceShape() in core/src/main/scala/org/apache/pekko/persistence/cassandra/query/EventsByTagStage.scala	640	110	1
override def createLogicAndMaterializedValue() in core/src/main/scala/org/apache/pekko/persistence/cassandra/query/EventsByPersistenceIdStage.scala	315	85	1
def deleteMessages() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournalStatements.scala	107	27	1
private def delete() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournal.scala	92	7	2
def createLogic() in core/src/main/scala/org/apache/pekko/persistence/cassandra/query/AllPersistenceIdsStage.scala	85	26	1
private def writeInProgress() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriter.scala	81	20	4
@InternalApi private[pekko] def serializeEvent() in core/src/main/scala/org/apache/pekko/persistence/cassandra/package.scala	59	5	6
private[pekko] def scan() in core/src/main/scala/org/apache/pekko/persistence/cassandra/query/TagViewSequenceNumberScanner.scala	55	8	7
override def asyncReplayMessages() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournal.scala	53	4	4
private def migrateToTagViewsInternal() in core/src/main/scala/org/apache/pekko/persistence/cassandra/EventsByTagMigration.scala	52	5	4
override def asyncWriteMessages() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournal.scala	51	9	1
def start() in cassandra-launcher/src/main/scala/org/apache/pekko/persistence/cassandra/testkit/CassandraLauncher.scala	50	5	4
def deserializeEvent() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournal.scala	45	11	2
private def startForked() in cassandra-launcher/src/main/scala/org/apache/pekko/persistence/cassandra/testkit/CassandraLauncher.scala	45	6	5
def main() in example/src/main/scala/org/apache/pekko/persistence/cassandra/example/Main.scala	44	5	1
def deserializeSnapshot() in core/src/main/scala/org/apache/pekko/persistence/cassandra/snapshot/CassandraSnapshotStore.scala	43	10	1
def writeBatch() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriters.scala	42	7	2
private def behavior() in example/src/main/scala/org/apache/pekko/persistence/cassandra/example/ReadSide.scala	40	4	4
override def eventsByTag() in core/src/main/scala/org/apache/pekko/persistence/cassandra/query/scaladsl/CassandraReadJournal.scala	40	5	2
def apply() in core/src/main/scala/org/apache/pekko/persistence/cassandra/query/EventsByTagStage.scala	40	1	10
override def asyncReadHighestSequenceNr() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournal.scala	40	10	2
private def sendPreSnapshotTagWrites() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournal.scala	40	4	7
def sendMissingTagWrite() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraTagRecovery.scala	40	6	2
private def idle() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriter.scala	39	15	3
private def issueSnapshotDelete() in core/src/main/scala/org/apache/pekko/persistence/cassandra/cleanup/Cleanup.scala	38	7	3
override def currentEventsByTag() in core/src/main/scala/org/apache/pekko/persistence/cassandra/query/scaladsl/CassandraReadJournal.scala	38	5	2
final def add() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/Buffer.scala	38	8	1
private def statementGroup() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournal.scala	38	2	1
private def writeTagScanning() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriters.scala	37	6	0
@InternalApi private[pekko] def eventsByPersistenceId[T]() in core/src/main/scala/org/apache/pekko/persistence/cassandra/query/scaladsl/CassandraReadJournal.scala	35	1	9
override def deleteAsync() in core/src/main/scala/org/apache/pekko/persistence/cassandra/snapshot/CassandraSnapshotStore.scala	35	6	2
private def loadNAsync() in core/src/main/scala/org/apache/pekko/persistence/cassandra/snapshot/CassandraSnapshotStore.scala	33	9	1
private[pekko] def props() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriter.scala	33	16	4
def initialize() in core/src/main/scala/org/apache/pekko/persistence/cassandra/query/scaladsl/CassandraReadJournal.scala	31	2	0
def getReplicationStrategy() in core/src/main/scala/org/apache/pekko/persistence/cassandra/PluginSettings.scala	31	8	3
def apply() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriters.scala	31	15	2
def apply() in core/src/main/scala/org/apache/pekko/persistence/cassandra/EventsByTagMigration.scala	30	4	1
def serialize() in core/src/main/scala/org/apache/pekko/persistence/cassandra/snapshot/CassandraSnapshotStore.scala	30	5	2
private def extractPersistentRepr() in core/src/main/scala/org/apache/pekko/persistence/cassandra/Extractors.scala	29	7	4
def executeCreateKeyspaceAndTables() in core/src/main/scala/org/apache/pekko/persistence/cassandra/snapshot/CassandraSnapshotStatements.scala	29	6	2
private def tagWriterTerminated() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriters.scala	29	6	1
private def retry[T]() in core/src/main/scala/org/apache/pekko/persistence/cassandra/Retries.scala	28	6	1
override def asyncDeleteMessagesTo() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournal.scala	27	4	2
def this() in core/src/main/scala/org/apache/pekko/persistence/cassandra/cleanup/Cleanup.scala	26	2	1
private def foreach() in core/src/main/scala/org/apache/pekko/persistence/cassandra/cleanup/Cleanup.scala	26	7	3
def deleteBeforeSnapshot() in core/src/main/scala/org/apache/pekko/persistence/cassandra/cleanup/Cleanup.scala	25	4	3
def execute() in core/src/main/scala/org/apache/pekko/persistence/cassandra/reconciler/DeleteTagViewForPersistenceId.scala	24	2	0
def reconcile() in core/src/main/scala/org/apache/pekko/persistence/cassandra/reconciler/BuildTagViewForPersistenceId.scala	24	2	1
protected def generateUUID() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournal.scala	24	9	1
private def asyncFindHighestSequenceNr() in core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournal.scala	24	4	3