sjyang18 commented on a change in pull request #4175:
URL: https://github.com/apache/nifi/pull/4175#discussion_r417678481
##########
File path:
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/FetchAzureBlobStorage.java
##########
@@ -49,10 +54,38 @@
@SeeAlso({ ListAzureBlobStorage.class, PutAzureBlobStorage.class,
DeleteAzureBlobStorage.class })
@InputRequirement(Requirement.INPUT_REQUIRED)
@WritesAttributes({
- @WritesAttribute(attribute = "azure.length", description = "The length of
the blob fetched")
+ @WritesAttribute(attribute = "azure.length", description = "The length of
the blob fetched"),
+ @WritesAttribute(attribute = "azure.user.metadata.___", description = "If
'Write User Metadata' is set to 'True', the user defined metadata associated to
the Blob object that is being listed " +
+ "will be written as part of the flowfile attributes")
})
public class FetchAzureBlobStorage extends AbstractAzureBlobProcessor {
+ protected static final PropertyDescriptor WRITE_USER_METADATA = new
PropertyDescriptor.Builder()
Review comment:
What if we move WRITE_USER_METADATA to AbstractAzureBlobProcesssor? Any
reason to define in sub classes and repeat?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]