You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by bt...@apache.org on 2020/03/23 02:29:38 UTC
[james-project] 06/08: JAMES-3121 Use LeveledCompationStrategy for
Cassandra eventStore table
This is an automated email from the ASF dual-hosted git repository.
btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit db80e3ee80864d38306ee1d059e1b0c80f49695f
Author: Gautier DI FOLCO <gd...@linagora.com>
AuthorDate: Thu Mar 19 10:50:06 2020 +0100
JAMES-3121 Use LeveledCompationStrategy for Cassandra eventStore table
---
.../eventstore/cassandra/CassandraEventStoreModule.scala | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
diff --git a/event-sourcing/event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStoreModule.scala b/event-sourcing/event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStoreModule.scala
index 189be31..b366cb7 100644
--- a/event-sourcing/event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStoreModule.scala
+++ b/event-sourcing/event-store-cassandra/src/main/scala/org/apache/james/eventsourcing/eventstore/cassandra/CassandraEventStoreModule.scala
@@ -26,9 +26,11 @@ import com.datastax.driver.core.schemabuilder.{Create, SchemaBuilder}
object CassandraEventStoreModule {
val MODULE = CassandraModule.table(CassandraEventStoreTable.EVENTS_TABLE)
.comment("Store events of a EventSourcing aggregate")
- .options((options: Create.Options) => options.caching(
- SchemaBuilder.KeyCaching.ALL,
- SchemaBuilder.rows(CassandraConstants.DEFAULT_CACHED_ROW_PER_PARTITION)))
+ .options((options: Create.Options) => options
+ .compactionOptions(SchemaBuilder.leveledStrategy())
+ .caching(
+ SchemaBuilder.KeyCaching.ALL,
+ SchemaBuilder.rows(CassandraConstants.DEFAULT_CACHED_ROW_PER_PARTITION)))
.statement(_.addPartitionKey(CassandraEventStoreTable.AGGREGATE_ID, DataType.varchar)
.addClusteringColumn(CassandraEventStoreTable.EVENT_ID, DataType.cint)
.addColumn(CassandraEventStoreTable.EVENT, DataType.text))
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org