akka.persistence.update.cassandra.scaladsl
akka.persistence.update.scaladsl.JournalTransformer implementation for Cassandra.
akka.persistence.update.scaladsl.JournalTransformer
It is retrieved with:
val transformer = JournalUpdater(system).journalUpdaterFor[CassandraJournalTransformer](CassandraJournalTransformer.Identifier)
Corresponding Java API is in akka.persistence.update.cassandra.javadsl.CassandraJournalTransformer.
Configuration settings can be defined in the configuration section with the absolute path corresponding to the identifier, which is "cassandra-journal-updater" for the default CassandraJournalTransformer#Identifier. See reference.conf.
"cassandra-journal-updater"
reference.conf
Transform all persistence ids.
Transform all persistence ids. It is expected that this is an expensive operation.
Transform a single persistenceId.
akka.persistence.update.scaladsl.JournalTransformer
implementation for Cassandra.It is retrieved with:
val transformer = JournalUpdater(system).journalUpdaterFor[CassandraJournalTransformer](CassandraJournalTransformer.Identifier)
Corresponding Java API is in akka.persistence.update.cassandra.javadsl.CassandraJournalTransformer.
Configuration settings can be defined in the configuration section with the absolute path corresponding to the identifier, which is
"cassandra-journal-updater"
for the default CassandraJournalTransformer#Identifier. Seereference.conf
.