diff --git a/nifi/nifi-api/src/main/java/org/apache/nifi/provenance/lineage/LineageNode.java b/nifi/nifi-api/src/main/java/org/apache/nifi/provenance/lineage/LineageNode.java index c50cdf5840..56e865f1f9 100644 --- a/nifi/nifi-api/src/main/java/org/apache/nifi/provenance/lineage/LineageNode.java +++ b/nifi/nifi-api/src/main/java/org/apache/nifi/provenance/lineage/LineageNode.java @@ -22,6 +22,7 @@ public interface LineageNode { * @return the identifier of the Clustered NiFi Node that generated the * event */ + @Deprecated String getClusterNodeIdentifier(); /** diff --git a/nifi/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/lineage/EventNode.java b/nifi/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/lineage/EventNode.java index 12d9a4ff5e..1f8d1dcd46 100644 --- a/nifi/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/lineage/EventNode.java +++ b/nifi/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/lineage/EventNode.java @@ -36,11 +36,13 @@ public class EventNode implements ProvenanceEventLineageNode { return String.valueOf(getEventIdentifier()); } + @Deprecated @Override public String getClusterNodeIdentifier() { return clusterNodeIdentifier; } + @Deprecated public void setClusterNodeIdentifier(final String nodeIdentifier) { this.clusterNodeIdentifier = nodeIdentifier; } diff --git a/nifi/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/lineage/FlowFileNode.java b/nifi/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/lineage/FlowFileNode.java index fdc7470d99..94e7661aed 100644 --- a/nifi/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/lineage/FlowFileNode.java +++ b/nifi/nifi-commons/nifi-data-provenance-utils/src/main/java/org/apache/nifi/provenance/lineage/FlowFileNode.java @@ -39,6 +39,7 @@ public class FlowFileNode implements LineageNode { return creationTime; } + @Deprecated @Override public String getClusterNodeIdentifier() { return clusterNodeIdentifier;