From 1c02a601bc359d9a7465c2fa38c9eec9b953e2a3 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Tue, 16 Aug 2022 19:50:53 +0200
Subject: [PATCH] Add NoFilter

---
 src/main/data-generator/quic-rpc.yaml                          | 3 +++
 .../dbengine/database/disk/LLLocalKeyValueDatabase.java        | 3 +++
 2 files changed, 6 insertions(+)

diff --git a/src/main/data-generator/quic-rpc.yaml b/src/main/data-generator/quic-rpc.yaml
index a92c6b9..a5efb15 100644
--- a/src/main/data-generator/quic-rpc.yaml
+++ b/src/main/data-generator/quic-rpc.yaml
@@ -99,6 +99,7 @@ versions:
         StandardFSDirectoryOptions
       ]
       Filter: [
+        NoFilter,
         BloomFilter
       ]
       ColumnOptions: [
@@ -295,6 +296,8 @@ versions:
           minBlobSize: -long
           blobFileSize: -long
           blobCompressionType: -Compression
+      NoFilter:
+        data: {}
       BloomFilter:
         data:
           bitsPerKey: int
diff --git a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java
index 686304a..418b309 100644
--- a/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java
+++ b/src/main/java/it/cavallium/dbengine/database/disk/LLLocalKeyValueDatabase.java
@@ -30,6 +30,7 @@ import it.cavallium.dbengine.rpc.current.data.DatabaseLevel;
 import it.cavallium.dbengine.rpc.current.data.DatabaseOptions;
 import it.cavallium.dbengine.rpc.current.data.DatabaseVolume;
 import it.cavallium.dbengine.rpc.current.data.NamedColumnOptions;
+import it.cavallium.dbengine.rpc.current.data.NoFilter;
 import java.io.File;
 import java.io.IOException;
 import java.lang.invoke.MethodHandles;
@@ -335,6 +336,8 @@ public class LLLocalKeyValueDatabase extends Backuppable implements LLKeyValueDa
 						final BloomFilter bloomFilter = new BloomFilter(bloomFilterOptions.bitsPerKey());
 						refs.track(bloomFilter);
 						tableOptions.setFilterPolicy(bloomFilter);
+					} else if (filterOptions instanceof NoFilter) {
+						tableOptions.setFilterPolicy(null);
 					}
 				}
 				boolean cacheIndexAndFilterBlocks = columnOptions.cacheIndexAndFilterBlocks()