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 bd6074cb689517061ecef9ddca3ab7a88d133cda Author: Gautier DI FOLCO <[email protected]> AuthorDate: Thu Mar 19 11:05:00 2020 +0100 JAMES-3121 Increase bloom_filter_fp_chance for Cassandra tables --- .../james/mailbox/cassandra/modules/CassandraAttachmentModule.java | 1 + .../james/mailbox/cassandra/modules/CassandraFirstUnseenModule.java | 1 + .../james/mailbox/cassandra/modules/CassandraMailboxCounterModule.java | 1 + .../org/apache/james/mailbox/cassandra/modules/CassandraUidModule.java | 1 + .../queue/rabbitmq/view/cassandra/CassandraMailQueueViewModule.java | 1 + 5 files changed, 5 insertions(+) diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraAttachmentModule.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraAttachmentModule.java index bb2604e..1db8dfc 100644 --- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraAttachmentModule.java +++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraAttachmentModule.java @@ -69,6 +69,7 @@ public interface CassandraAttachmentModule { .comment("Holds explicit owners of some attachments") .options(options -> options .compactionOptions(SchemaBuilder.leveledStrategy()) + .bloomFilterFPChance(0.01) .caching(SchemaBuilder.KeyCaching.ALL, SchemaBuilder.rows(CassandraConstants.DEFAULT_CACHED_ROW_PER_PARTITION))) .statement(statement -> statement diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraFirstUnseenModule.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraFirstUnseenModule.java index c7713a0..9b54e34 100644 --- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraFirstUnseenModule.java +++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraFirstUnseenModule.java @@ -31,6 +31,7 @@ public interface CassandraFirstUnseenModule { .comment("Denormalisation table. Allow to quickly retrieve the first UNSEEN UID of a specific mailbox.") .options(options -> options .compactionOptions(SchemaBuilder.sizedTieredStategy()) + .bloomFilterFPChance(0.01) .caching(SchemaBuilder.KeyCaching.ALL, SchemaBuilder.rows(CassandraConstants.DEFAULT_CACHED_ROW_PER_PARTITION)) .clusteringOrder(CassandraFirstUnseenTable.UID, SchemaBuilder.Direction.ASC)) diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraMailboxCounterModule.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraMailboxCounterModule.java index 71dbff9..14ebc86 100644 --- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraMailboxCounterModule.java +++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraMailboxCounterModule.java @@ -33,6 +33,7 @@ public interface CassandraMailboxCounterModule { .comment("Holds messages count and unseen message count for each mailbox.") .options(options -> options .compactionOptions(SchemaBuilder.sizedTieredStategy()) + .bloomFilterFPChance(0.01) .caching(SchemaBuilder.KeyCaching.ALL, SchemaBuilder.rows(CassandraConstants.DEFAULT_CACHED_ROW_PER_PARTITION))) .statement(statement -> statement diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraUidModule.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraUidModule.java index 5df1451..47fd98a 100644 --- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraUidModule.java +++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/modules/CassandraUidModule.java @@ -33,6 +33,7 @@ public interface CassandraUidModule { .comment("Holds and is used to generate UID. A monotic counter is implemented on top of this table.") .options(options -> options .compactionOptions(SchemaBuilder.sizedTieredStategy()) + .bloomFilterFPChance(0.01) .caching(SchemaBuilder.KeyCaching.ALL, SchemaBuilder.rows(CassandraConstants.DEFAULT_CACHED_ROW_PER_PARTITION))) .statement(statement -> statement diff --git a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/CassandraMailQueueViewModule.java b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/CassandraMailQueueViewModule.java index 518fe3b..fadd939 100644 --- a/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/CassandraMailQueueViewModule.java +++ b/server/queue/queue-rabbitmq/src/main/java/org/apache/james/queue/rabbitmq/view/cassandra/CassandraMailQueueViewModule.java @@ -126,6 +126,7 @@ public interface CassandraMailQueueViewModule { "existence in this table") .options(options -> options .compactionOptions(SchemaBuilder.timeWindowCompactionStrategy()) + .bloomFilterFPChance(0.01) .readRepairChance(NO_READ_REPAIR)) .statement(statement -> statement .addPartitionKey(DeletedMailTable.QUEUE_NAME, text()) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
