1
0
mirror of https://github.com/apache/nifi.git synced 2025-02-16 15:06:00 +00:00

NIFI-12775: Renamed provenance/FileResource to ProvenanceFileResource

This closes .

Signed-off-by: Peter Turcsanyi <turcsanyi@apache.org>
This commit is contained in:
lehelb 2024-02-10 20:27:57 -05:00 committed by Peter Turcsanyi
parent b6b0b241c3
commit bf86103abf
No known key found for this signature in database
GPG Key ID: 55A813F1C3E553DC
4 changed files with 10 additions and 10 deletions
nifi-api/src/main/java/org/apache/nifi/provenance
nifi-mock/src/main/java/org/apache/nifi/util
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-components/src/main/java/org/apache/nifi/controller/repository

@ -20,10 +20,10 @@ package org.apache.nifi.provenance;
* Holds information of a file resource for UPLOAD * Holds information of a file resource for UPLOAD
* provenance events. * provenance events.
*/ */
public record FileResource(String location, long size) { public record ProvenanceFileResource(String location, long size) {
@Override @Override
public String toString() { public String toString() {
return "FileResource[location=%s, size=%d]".formatted(location, size); return "ProvenanceFileResource[location=%s, size=%d]".formatted(location, size);
} }
} }

@ -330,7 +330,7 @@ public interface ProvenanceReporter {
* events to an external Enterprise-wide system that is then able to * events to an external Enterprise-wide system that is then able to
* correlate the SEND and RECEIVE events. * correlate the SEND and RECEIVE events.
*/ */
void upload(FlowFile flowFile, FileResource fileResource, String transitUri); void upload(FlowFile flowFile, ProvenanceFileResource fileResource, String transitUri);
/** /**
* Emits a Provenance Event of type {@link ProvenanceEventType#UPLOAD UPLOAD} * Emits a Provenance Event of type {@link ProvenanceEventType#UPLOAD UPLOAD}
@ -355,7 +355,7 @@ public interface ProvenanceReporter {
* ProvenanceReporter is associated is rolled back. Otherwise, the Event * ProvenanceReporter is associated is rolled back. Otherwise, the Event
* will be recorded only on a successful session commit. * will be recorded only on a successful session commit.
*/ */
void upload(FlowFile flowFile, FileResource fileResource, String transitUri, String details, long transmissionMillis, boolean force); void upload(FlowFile flowFile, ProvenanceFileResource fileResource, String transitUri, String details, long transmissionMillis, boolean force);
/** /**
* Emits a Provenance Event of type {@link ProvenanceEventType#REMOTE_INVOCATION} * Emits a Provenance Event of type {@link ProvenanceEventType#REMOTE_INVOCATION}

@ -24,7 +24,7 @@ import org.apache.nifi.provenance.ProvenanceEventRecord;
import org.apache.nifi.provenance.ProvenanceEventType; import org.apache.nifi.provenance.ProvenanceEventType;
import org.apache.nifi.provenance.ProvenanceReporter; import org.apache.nifi.provenance.ProvenanceReporter;
import org.apache.nifi.provenance.StandardProvenanceEventRecord; import org.apache.nifi.provenance.StandardProvenanceEventRecord;
import org.apache.nifi.provenance.FileResource; import org.apache.nifi.provenance.ProvenanceFileResource;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -228,13 +228,13 @@ public class MockProvenanceReporter implements ProvenanceReporter {
} }
@Override @Override
public void upload(final FlowFile flowFile, final FileResource fileResource, final String transitUri) { public void upload(final FlowFile flowFile, final ProvenanceFileResource fileResource, final String transitUri) {
upload(flowFile, fileResource, transitUri, null, -1L, true); upload(flowFile, fileResource, transitUri, null, -1L, true);
} }
@Override @Override
public void upload(FlowFile flowFile, FileResource fileResource, String transitUri, String details, long transmissionMillis, boolean force) { public void upload(FlowFile flowFile, ProvenanceFileResource fileResource, String transitUri, String details, long transmissionMillis, boolean force) {
try { try {
final String fileResourceDetails = fileResource.toString(); final String fileResourceDetails = fileResource.toString();
final String enrichedDetails = details == null ? fileResourceDetails : details + " " + fileResourceDetails; final String enrichedDetails = details == null ? fileResourceDetails : details + " " + fileResourceDetails;

@ -24,7 +24,7 @@ import org.apache.nifi.provenance.ProvenanceEventBuilder;
import org.apache.nifi.provenance.ProvenanceEventRecord; import org.apache.nifi.provenance.ProvenanceEventRecord;
import org.apache.nifi.provenance.ProvenanceEventRepository; import org.apache.nifi.provenance.ProvenanceEventRepository;
import org.apache.nifi.provenance.ProvenanceEventType; import org.apache.nifi.provenance.ProvenanceEventType;
import org.apache.nifi.provenance.FileResource; import org.apache.nifi.provenance.ProvenanceFileResource;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -282,12 +282,12 @@ public class StandardProvenanceReporter implements InternalProvenanceReporter {
} }
@Override @Override
public void upload(final FlowFile flowFile, final FileResource fileResource, final String transitUri) { public void upload(final FlowFile flowFile, final ProvenanceFileResource fileResource, final String transitUri) {
upload(flowFile, fileResource, transitUri, null, -1L, true); upload(flowFile, fileResource, transitUri, null, -1L, true);
} }
@Override @Override
public void upload(final FlowFile flowFile, final FileResource fileResource, final String transitUri, final String details, final long transmissionMillis, final boolean force) { public void upload(final FlowFile flowFile, final ProvenanceFileResource fileResource, final String transitUri, final String details, final long transmissionMillis, final boolean force) {
try { try {
final String fileResourceDetails = fileResource.toString(); final String fileResourceDetails = fileResource.toString();
final String enrichedDetails = details == null ? fileResourceDetails : details + " " + fileResourceDetails; final String enrichedDetails = details == null ? fileResourceDetails : details + " " + fileResourceDetails;