This is an automated email from the ASF dual-hosted git repository.
exceptionfactory 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 313b71a8c16 NIFI-16105 Upgraded NiFi API from 2.9.0 to 2.10.0 (#11421)
313b71a8c16 is described below
commit 313b71a8c167c420db17cc6fd210423ce7eb06cb
Author: Pierre Villard <[email protected]>
AuthorDate: Mon Jul 13 16:47:37 2026 +0200
NIFI-16105 Upgraded NiFi API from 2.9.0 to 2.10.0 (#11421)
Signed-off-by: David Handermann <[email protected]>
---
.../facades/standalone/StandaloneConnectionFacade.java | 6 ++++++
.../facades/standalone/StandaloneProcessorFacade.java | 13 +++++++++++++
.../authorization/AuthorizingConnectionFacade.java | 7 +++++++
.../authorization/AuthorizingProcessorFacade.java | 15 +++++++++++++++
pom.xml | 2 +-
5 files changed, 42 insertions(+), 1 deletion(-)
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/components/connector/facades/standalone/StandaloneConnectionFacade.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/components/connector/facades/standalone/StandaloneConnectionFacade.java
index cc21353731d..a5d32a6c1bd 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/components/connector/facades/standalone/StandaloneConnectionFacade.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/components/connector/facades/standalone/StandaloneConnectionFacade.java
@@ -19,6 +19,7 @@ package
org.apache.nifi.components.connector.facades.standalone;
import org.apache.nifi.components.connector.DropFlowFileSummary;
import org.apache.nifi.components.connector.components.ConnectionFacade;
+import org.apache.nifi.components.connector.components.QueueSnapshot;
import org.apache.nifi.connectable.Connection;
import org.apache.nifi.controller.queue.QueueSize;
import org.apache.nifi.flow.VersionedConnection;
@@ -58,6 +59,11 @@ public class StandaloneConnectionFacade implements
ConnectionFacade {
return connection.getFlowFileQueue().dropFlowFiles(predicate);
}
+ @Override
+ public QueueSnapshot getQueueSnapshot() {
+ throw new UnsupportedOperationException("Queue snapshots not yet
implemented");
+ }
+
@Override
public String toString() {
return "StandaloneConnectionFacade[id=" +
versionedConnection.getIdentifier() + ", name=" + versionedConnection.getName()
+ "]";
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/components/connector/facades/standalone/StandaloneProcessorFacade.java
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/components/connector/facades/standalone/StandaloneProcessorFacade.java
index 3de26ad4431..9c33370cafa 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/components/connector/facades/standalone/StandaloneProcessorFacade.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/components/connector/facades/standalone/StandaloneProcessorFacade.java
@@ -22,6 +22,8 @@ import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.DeserializationFeature;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.nifi.asset.AssetManager;
+import org.apache.nifi.components.Backlog;
+import org.apache.nifi.components.BacklogReportingException;
import org.apache.nifi.components.ConfigVerificationResult;
import org.apache.nifi.components.ValidationContext;
import org.apache.nifi.components.ValidationResult;
@@ -49,6 +51,7 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Objects;
+import java.util.Optional;
public class StandaloneProcessorFacade implements ProcessorFacade {
private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper()
@@ -209,6 +212,16 @@ public class StandaloneProcessorFacade implements
ProcessorFacade {
}
}
+ @Override
+ public boolean reportsBacklog() {
+ return false;
+ }
+
+ @Override
+ public Optional<Backlog> getBacklog() throws BacklogReportingException {
+ return Optional.empty();
+ }
+
@Override
public String toString() {
final String type = versionedProcessor.getType();
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/connector/authorization/AuthorizingConnectionFacade.java
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/connector/authorization/AuthorizingConnectionFacade.java
index ea72b197f6b..eb40315595b 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/connector/authorization/AuthorizingConnectionFacade.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/connector/authorization/AuthorizingConnectionFacade.java
@@ -18,6 +18,7 @@ package org.apache.nifi.web.connector.authorization;
import org.apache.nifi.components.connector.DropFlowFileSummary;
import org.apache.nifi.components.connector.components.ConnectionFacade;
+import org.apache.nifi.components.connector.components.QueueSnapshot;
import org.apache.nifi.controller.queue.QueueSize;
import org.apache.nifi.flow.VersionedConnection;
import org.apache.nifi.flowfile.FlowFile;
@@ -64,6 +65,12 @@ public class AuthorizingConnectionFacade implements
ConnectionFacade {
return delegate.dropFlowFiles(predicate);
}
+ @Override
+ public QueueSnapshot getQueueSnapshot() {
+ authContext.authorizeRead();
+ return delegate.getQueueSnapshot();
+ }
+
@Override
public String toString() {
return "AuthorizingConnectionFacade[delegate=" + delegate + "]";
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/connector/authorization/AuthorizingProcessorFacade.java
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/connector/authorization/AuthorizingProcessorFacade.java
index d392d2c2b9f..14c8c4c6fed 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/connector/authorization/AuthorizingProcessorFacade.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/connector/authorization/AuthorizingProcessorFacade.java
@@ -16,6 +16,8 @@
*/
package org.apache.nifi.web.connector.authorization;
+import org.apache.nifi.components.Backlog;
+import org.apache.nifi.components.BacklogReportingException;
import org.apache.nifi.components.ConfigVerificationResult;
import org.apache.nifi.components.ValidationResult;
import org.apache.nifi.components.connector.InvocationFailedException;
@@ -28,6 +30,7 @@ import org.apache.nifi.flow.VersionedProcessor;
import java.util.List;
import java.util.Map;
import java.util.Objects;
+import java.util.Optional;
/**
* A wrapper around {@link ProcessorFacade} that enforces authorization before
delegating
@@ -97,6 +100,18 @@ public class AuthorizingProcessorFacade implements
ProcessorFacade {
return delegate.invokeConnectorMethod(methodName, arguments,
returnType);
}
+ @Override
+ public boolean reportsBacklog() {
+ authContext.authorizeRead();
+ return delegate.reportsBacklog();
+ }
+
+ @Override
+ public Optional<Backlog> getBacklog() throws BacklogReportingException {
+ authContext.authorizeRead();
+ return delegate.getBacklog();
+ }
+
@Override
public String toString() {
return "AuthorizingProcessorFacade[delegate=" + delegate + "]";
diff --git a/pom.xml b/pom.xml
index eb36e2e0322..a8cbbb9f7de 100644
--- a/pom.xml
+++ b/pom.xml
@@ -118,7 +118,7 @@
<node.version>v24.14.1</node.version>
<!-- NiFi build -->
- <nifi-api.version>2.9.0</nifi-api.version>
+ <nifi-api.version>2.10.0</nifi-api.version>
<nifi.nar.maven.plugin.version>2.3.0</nifi.nar.maven.plugin.version>
<!-- CSPs SDK -->
