diff --git a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage.java b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage.java index b9c1ecb807..cdbb59a7b0 100644 --- a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage.java +++ b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/ListAzureBlobStorage.java @@ -106,7 +106,8 @@ public class ListAzureBlobStorage extends AbstractListProcessor { attributes.put("azure.etag", entity.getEtag()); attributes.put("azure.primaryUri", entity.getPrimaryUri()); attributes.put("azure.secondaryUri", entity.getSecondaryUri()); - attributes.put("azure.blobname", entity.getName()); + attributes.put("azure.blobname", entity.getBlobName()); + attributes.put("filename", entity.getName()); attributes.put("azure.blobtype", entity.getBlobType()); attributes.put("azure.length", String.valueOf(entity.getLength())); attributes.put("azure.timestamp", String.valueOf(entity.getTimestamp())); @@ -163,6 +164,7 @@ public class ListAzureBlobStorage extends AbstractListProcessor { Builder builder = new BlobInfo.Builder() .primaryUri(uri.getPrimaryUri().toString()) + .blobName(cloudBlob.getName()) .containerName(containerName) .contentType(properties.getContentType()) .contentLanguage(properties.getContentLanguage()) diff --git a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/BlobInfo.java b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/BlobInfo.java index 36fb1df512..6343dc8126 100644 --- a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/BlobInfo.java +++ b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/utils/BlobInfo.java @@ -31,6 +31,7 @@ public class BlobInfo implements Comparable, Serializable, ListableEnt private final long lastModifiedTime; private final long length; private final String blobType; + private final String blobName; private final String containerName; public static long getSerialversionuid() { @@ -57,6 +58,10 @@ public class BlobInfo implements Comparable, Serializable, ListableEnt return containerName; } + public String getBlobName() { + return blobName; + } + public String getEtag() { return etag; } @@ -83,6 +88,7 @@ public class BlobInfo implements Comparable, Serializable, ListableEnt private long length; private String blobType; private String containerName; + private String blobName; public Builder primaryUri(String primaryUri) { this.primaryUri = primaryUri; @@ -129,6 +135,11 @@ public class BlobInfo implements Comparable, Serializable, ListableEnt return this; } + public Builder blobName(String blobName) { + this.blobName = blobName; + return this; + } + public BlobInfo build() { return new BlobInfo(this); } @@ -180,6 +191,7 @@ public class BlobInfo implements Comparable, Serializable, ListableEnt this.lastModifiedTime = builder.lastModifiedTime; this.length = builder.length; this.blobType = builder.blobType; + this.blobName = builder.blobName; } @Override