This is an automated email from the ASF dual-hosted git repository.
pvillard pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 87d70bd98c1 NIFI-15627 Added Record Gauge support to
ExecuteGroovyScript
87d70bd98c1 is described below
commit 87d70bd98c1c2f3e785c3d6db3ac75e4189b4af5
Author: exceptionfactory <[email protected]>
AuthorDate: Thu Feb 19 09:50:16 2026 -0600
NIFI-15627 Added Record Gauge support to ExecuteGroovyScript
This closes #10921.
Signed-off-by: Pierre Villard <[email protected]>
---
.../org/apache/nifi/processors/groovyx/flow/ProcessSessionWrap.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git
a/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/flow/ProcessSessionWrap.java
b/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/flow/ProcessSessionWrap.java
index aec133cbaca..77cb00b6385 100644
---
a/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/flow/ProcessSessionWrap.java
+++
b/nifi-extension-bundles/nifi-groovyx-bundle/nifi-groovyx-processors/src/main/java/org/apache/nifi/processors/groovyx/flow/ProcessSessionWrap.java
@@ -30,6 +30,7 @@ import org.apache.nifi.processor.exception.ProcessException;
import org.apache.nifi.processor.io.InputStreamCallback;
import org.apache.nifi.processor.io.OutputStreamCallback;
import org.apache.nifi.processor.io.StreamCallback;
+import org.apache.nifi.processor.metrics.CommitTiming;
import org.apache.nifi.processors.groovyx.util.Throwables;
import org.apache.nifi.provenance.ProvenanceReporter;
@@ -311,6 +312,11 @@ public abstract class ProcessSessionWrap implements
ProcessSession {
session.adjustCounter(name, delta, immediate);
}
+ @Override
+ public void recordGauge(final String name, final double value, final
CommitTiming commitTiming) {
+ session.recordGauge(name, value, commitTiming);
+ }
+
/**
* @return FlowFile that is next highest priority FlowFile to process.
Otherwise returns null.
*/
