diff --git a/bundles/io.github.linkedfactory.core/src/main/java/io/github/linkedfactory/core/kvin/parquet/Compactor.java b/bundles/io.github.linkedfactory.core/src/main/java/io/github/linkedfactory/core/kvin/parquet/Compactor.java
index a83d15e9..4b949a79 100644
--- a/bundles/io.github.linkedfactory.core/src/main/java/io/github/linkedfactory/core/kvin/parquet/Compactor.java
+++ b/bundles/io.github.linkedfactory.core/src/main/java/io/github/linkedfactory/core/kvin/parquet/Compactor.java
@@ -26,12 +26,18 @@ public class Compactor {
 	final KvinParquet kvinParquet;
 	final File compactionFolder;
 	String archiveLocation;
-	int dataFileCompactionTrigger = 3, mappingFileCompactionTrigger = 3;
+	int dataFileCompactionTrigger, mappingFileCompactionTrigger;
 
 	public Compactor(KvinParquet kvinParquet) {
+		this(kvinParquet, 3, 3);
+	}
+
+	public Compactor(KvinParquet kvinParquet, int dataFileCompactionTrigger, int mappingFileCompactionTrigger) {
 		this.archiveLocation = kvinParquet.archiveLocation;
 		this.compactionFolder = new File(archiveLocation, ".compaction");
 		this.kvinParquet = kvinParquet;
+		this.dataFileCompactionTrigger = dataFileCompactionTrigger;
+		this.mappingFileCompactionTrigger = mappingFileCompactionTrigger;
 	}
 
 	public void execute() throws IOException {
diff --git a/bundles/io.github.linkedfactory.core/src/test/java/io/github/linkedfactory/core/kvin/parquet/KvinParquetTest.java b/bundles/io.github.linkedfactory.core/src/test/java/io/github/linkedfactory/core/kvin/parquet/KvinParquetTest.java
index 33c36e71..ab2c6437 100644
--- a/bundles/io.github.linkedfactory.core/src/test/java/io/github/linkedfactory/core/kvin/parquet/KvinParquetTest.java
+++ b/bundles/io.github.linkedfactory.core/src/test/java/io/github/linkedfactory/core/kvin/parquet/KvinParquetTest.java
@@ -128,7 +128,7 @@ public void shouldDoFetchForNonSeqEntry() {
 
 	@Test
 	public void mappingFileCompactionTest() throws IOException, InterruptedException {
-		new Compactor(kvinParquet).execute();
+		new Compactor(kvinParquet, 1, 1).execute();
 
 		File[] metadataFiles = new File(kvinParquet.archiveLocation, "metadata")
 				.listFiles((file, s) -> s.endsWith(".parquet"));