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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to