From f83542cfa8a438c1d531f3def29e8ab0be1f71e1 Mon Sep 17 00:00:00 2001
From: TobiasNx <tobias.buelte@hbz-nrw.de>
Date: Tue, 25 Aug 2026 09:58:36 +0200
Subject: [PATCH] Add setter to for datatype int #782

Reuse adjustment from ObjectSleeper.java 18b6ae0cc0446c4cbe0dc6ed6127b21d69914e26
---
 .../metafacture/plumbing/StreamBatchMerger.java    | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/metafacture-plumbing/src/main/java/org/metafacture/plumbing/StreamBatchMerger.java b/metafacture-plumbing/src/main/java/org/metafacture/plumbing/StreamBatchMerger.java
index c422ab23a..cff776ff3 100644
--- a/metafacture-plumbing/src/main/java/org/metafacture/plumbing/StreamBatchMerger.java
+++ b/metafacture-plumbing/src/main/java/org/metafacture/plumbing/StreamBatchMerger.java
@@ -51,6 +51,20 @@ public final class StreamBatchMerger extends DefaultStreamPipe<StreamReceiver> {
     public StreamBatchMerger() {
     }
 
+    /**
+     * Sets the number of records that should be merged into a batch.
+     * <p>
+     * The default batch size is 1, wich means that no records are merged.
+     * <p>
+     * This parameter must not be changed during processing.
+     *
+     * @param batchSize the number of records that should be merged.
+     */
+    public void setBatchSize(final int batchSize) {
+        // NOTE: ConfigurableClass.convertValue() doesn't support long.
+        setBatchSize((long) batchSize);
+    }
+
     /**
      * Sets the number of records that should be merged into a batch.
      * <p>