path	# lines of code
cassandra-bundle/src/main/resources/logback.xml	13
project/CopyrightHeader.scala	96
project/Dependencies.scala	33
project/plugins.sbt	15
project/PekkoManagementDependency.scala	6
project/PekkoConnectorsDependency.scala	6
project/Common.scala	59
project/MetaInfLicenseNoticeCopy.scala	7
project/PekkoCoreDependency.scala	6
example/src/main/scala/org/apache/pekko/persistence/cassandra/example/EventProcessorStream.scala	100
example/src/main/scala/org/apache/pekko/persistence/cassandra/example/Reporter.scala	19
example/src/main/scala/org/apache/pekko/persistence/cassandra/example/LoadGenerator.scala	44
example/src/main/scala/org/apache/pekko/persistence/cassandra/example/Main.scala	57
example/src/main/scala/org/apache/pekko/persistence/cassandra/example/ReadSideTopic.scala	11
example/src/main/scala/org/apache/pekko/persistence/cassandra/example/ReadSide.scala	76
example/src/main/scala/org/apache/pekko/persistence/cassandra/example/ConfigurablePersistentActor.scala	29
example/src/main/scala/org/apache/pekko/persistence/cassandra/example/CborSerializable.scala	2
example/src/main/resources/logback.xml	16
example/kubernetes/load.yaml	45
example/kubernetes/cassandra.yaml	42
example/kubernetes/read.yaml	45
example/kubernetes/rbac.yaml	20
example/kubernetes/write.yaml	45
core/src/main/scala/org/apache/pekko/persistence/cassandra/CassandraStatements.scala	50
core/src/main/scala/org/apache/pekko/persistence/cassandra/cleanup/CleanupSettings.scala	13
core/src/main/scala/org/apache/pekko/persistence/cassandra/cleanup/Cleanup.scala	244
core/src/main/scala/org/apache/pekko/persistence/cassandra/EventsByTagSettings.scala	190
core/src/main/scala/org/apache/pekko/persistence/cassandra/Retries.scala	49
core/src/main/scala/org/apache/pekko/persistence/cassandra/query/CassandraReadJournalProvider.scala	14
core/src/main/scala/org/apache/pekko/persistence/cassandra/query/scaladsl/CassandraReadJournal.scala	460
core/src/main/scala/org/apache/pekko/persistence/cassandra/query/CassandraReadStatements.scala	37
core/src/main/scala/org/apache/pekko/persistence/cassandra/query/EventsByPersistenceIdStage.scala	391
core/src/main/scala/org/apache/pekko/persistence/cassandra/query/EventsByTagStage.scala	796
core/src/main/scala/org/apache/pekko/persistence/cassandra/query/AllPersistenceIdsStage.scala	110
core/src/main/scala/org/apache/pekko/persistence/cassandra/query/javadsl/CassandraReadJournal.scala	55
core/src/main/scala/org/apache/pekko/persistence/cassandra/query/MissingTaggedEventException.scala	10
core/src/main/scala/org/apache/pekko/persistence/cassandra/query/UUIDPersistentRepr.scala	10
core/src/main/scala/org/apache/pekko/persistence/cassandra/query/QuerySettings.scala	26
core/src/main/scala/org/apache/pekko/persistence/cassandra/query/package.scala	29
core/src/main/scala/org/apache/pekko/persistence/cassandra/query/TagViewSequenceNumberScanner.scala	95
core/src/main/scala/org/apache/pekko/persistence/cassandra/PluginSettings.scala	73
core/src/main/scala/org/apache/pekko/persistence/cassandra/KeyspaceAndTableStatements.scala	32
core/src/main/scala/org/apache/pekko/persistence/cassandra/reconciler/Reconciliation.scala	121
core/src/main/scala/org/apache/pekko/persistence/cassandra/reconciler/ReconciliationSettings.scala	7
core/src/main/scala/org/apache/pekko/persistence/cassandra/reconciler/DeleteTagViewForPersistenceId.scala	48
core/src/main/scala/org/apache/pekko/persistence/cassandra/reconciler/BuildTagViewForPersistenceId.scala	59
core/src/main/scala/org/apache/pekko/persistence/cassandra/reconciler/AllTags.scala	23
core/src/main/scala/org/apache/pekko/persistence/cassandra/Extractors.scala	169
core/src/main/scala/org/apache/pekko/persistence/cassandra/compaction/TimeWindowCompactionStrategy.scala	36
core/src/main/scala/org/apache/pekko/persistence/cassandra/compaction/SizeTieredCompactionStrategy.scala	43
core/src/main/scala/org/apache/pekko/persistence/cassandra/compaction/BaseCompactionStrategy.scala	57
core/src/main/scala/org/apache/pekko/persistence/cassandra/compaction/CassandraCompactionStrategy.scala	9
core/src/main/scala/org/apache/pekko/persistence/cassandra/compaction/CassandraCompactionStrategyConfig.scala	7
core/src/main/scala/org/apache/pekko/persistence/cassandra/compaction/LeveledCompactionStrategy.scala	25
core/src/main/scala/org/apache/pekko/persistence/cassandra/util/RetryableFutureEval.scala	27
core/src/main/scala/org/apache/pekko/persistence/cassandra/EventsByTagMigration.scala	161
core/src/main/scala/org/apache/pekko/persistence/cassandra/snapshot/SnapshotSettings.scala	25
core/src/main/scala/org/apache/pekko/persistence/cassandra/snapshot/CassandraSnapshotStore.scala	334
core/src/main/scala/org/apache/pekko/persistence/cassandra/snapshot/CassandraSnapshotStatements.scala	110
core/src/main/scala/org/apache/pekko/persistence/cassandra/healthcheck/HealthCheckSettings.scala	14
core/src/main/scala/org/apache/pekko/persistence/cassandra/healthcheck/CassandraHealthCheck.scala	30
core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/PubSubThrottler.scala	38
core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournalUnexpectedError.scala	3
core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraEventUpdate.scala	107
core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournalStatements.scala	321
core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TimeBucket.scala	55
core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/JournalSettings.scala	36
core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriters.scala	381
core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TagWriter.scala	279
core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/Buffer.scala	88
core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraJournal.scala	740
core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/CassandraTagRecovery.scala	135
core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/package.scala	6
core/src/main/scala/org/apache/pekko/persistence/cassandra/journal/TaggedPreparedStatements.scala	32
core/src/main/scala/org/apache/pekko/persistence/cassandra/package.scala	100
core/src/main/resources/test-embedded-cassandra.yaml	29
core/src/multi-jvm/scala/org/apache/pekko/cluster/persistence/cassandra/STMultiNodeSpec.scala	13
core/src/multi-jvm/scala/org/apache/pekko/cluster/persistence/cassandra/MultiNodeClusterSpec.scala	225
core/src/multi-jvm/scala/org/apache/pekko/cluster/persistence/cassandra/EventsByTagMultiJvmSpec.scala	128
docker-files/cassandra.yaml	129
docker-files/cassandra2.yaml	91
cassandra-launcher/src/main/scala/org/apache/pekko/persistence/cassandra/testkit/CassandraLauncher.scala	253
build.sbt	165