(nifi-api) branch main updated: NIFI-16270 Added maximum in-memory FlowFile content size to VersionedProcessGroup (#108)

[pvillard]

This is an automated email from the ASF dual-hosted git repository.

pvillard31 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-api.git


The following commit(s) were added to refs/heads/main by this push:
     new 308e20f  NIFI-16270 Added maximum in-memory FlowFile content size to 
VersionedProcessGroup (#108)
308e20f is described below

commit 308e20f291866524c4ebafe3d951a68d2101d7ce
Author: Mark Payne <marka...@hotmail.com>
AuthorDate: Tue Sep 15 12:24:29 2026 -0400

    NIFI-16270 Added maximum in-memory FlowFile content size to 
VersionedProcessGroup (#108)
---
 .../apache/nifi/flow/VersionedProcessGroup.java    | 24 ++++++++++++++++++++++
 1 file changed, 24 insertions(+)

diff --git a/src/main/java/org/apache/nifi/flow/VersionedProcessGroup.java 
b/src/main/java/org/apache/nifi/flow/VersionedProcessGroup.java
index e63c59b..c47d82e 100644
--- a/src/main/java/org/apache/nifi/flow/VersionedProcessGroup.java
+++ b/src/main/java/org/apache/nifi/flow/VersionedProcessGroup.java
@@ -46,6 +46,8 @@ public class VersionedProcessGroup extends VersionedComponent 
{
     private ExecutionEngine executionEngine;
     private Integer maxConcurrentTasks;
     private String statelessFlowTimeout;
+    private String statelessFlowFileContentInMemoryMax;
+    private Integer statelessFlowFileContentInMemoryHeapPercentage;
 
     private String logFileSuffix;
 
@@ -243,4 +245,26 @@ public class VersionedProcessGroup extends 
VersionedComponent {
     public void setStatelessFlowTimeout(final String timeout) {
         this.statelessFlowTimeout = timeout;
     }
+
+    @Schema(description = "The maximum amount of FlowFile content to buffer in 
memory when the Process Group is run using the Stateless Engine, as a data size 
such as " +
+            "\"4 GB\". A value of \"0 B\" means zero bytes. When this value is 
not set, only the heap percentage limit is used. When both this value and the 
heap percentage are set, " +
+            "the smaller of the two limits is used.")
+    public String getStatelessFlowFileContentInMemoryMax() {
+        return statelessFlowFileContentInMemoryMax;
+    }
+
+    public void setStatelessFlowFileContentInMemoryMax(final String 
statelessFlowFileContentInMemoryMax) {
+        this.statelessFlowFileContentInMemoryMax = 
statelessFlowFileContentInMemoryMax;
+    }
+
+    @Schema(description = "The maximum percentage of the Java heap to use for 
buffering FlowFile content when the Process Group is run using the Stateless 
Engine, from 0 to 90. " +
+            "A value of 0 means zero percent of the heap. When this value is 
not set, only the data size limit is used. When both this value and the data 
size maximum are set, " +
+            "the smaller of the two limits is used. The default is 0.")
+    public Integer getStatelessFlowFileContentInMemoryHeapPercentage() {
+        return statelessFlowFileContentInMemoryHeapPercentage;
+    }
+
+    public void setStatelessFlowFileContentInMemoryHeapPercentage(final 
Integer statelessFlowFileContentInMemoryHeapPercentage) {
+        this.statelessFlowFileContentInMemoryHeapPercentage = 
statelessFlowFileContentInMemoryHeapPercentage;
+    }
 }