This is an automated email from the ASF dual-hosted git repository.
joewitt 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 025109a9d8 NIFI-12123: This closes #7786. Added additional @UseCase
and @MultiProcessorUseCase annotations as well as some trivial cleanup that was
flagged by IntelliJ such as making inner class static, updating some deprecated
references, etc.
025109a9d8 is described below
commit 025109a9d89b78136e888c69b8fbb817a75ae33e
Author: Mark Payne
AuthorDate: Mon Sep 25 09:04:44 2023 -0400
NIFI-12123: This closes #7786. Added additional @UseCase and
@MultiProcessorUseCase annotations as well as some trivial cleanup that was
flagged by IntelliJ such as making inner class static, updating some deprecated
references, etc.
Signed-off-by: Joseph Witt
---
.../azure/storage/FetchAzureBlobStorage_v12.java | 44 +---
.../azure/storage/FetchAzureDataLakeStorage.java | 42 ++--
.../processors/gcp/drive/FetchGoogleDrive.java | 80 +-
.../processors/gcp/storage/FetchGCSObject.java | 53 ++
.../apache/nifi/processors/standard/FetchFTP.java | 35 +-
.../apache/nifi/processors/standard/FetchSFTP.java | 33 -
.../processors/standard/RemoveRecordField.java | 22 +-
7 files changed, 243 insertions(+), 66 deletions(-)
diff --git
a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/FetchAzureBlobStorage_v12.java
b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/FetchAzureBlobStorage_v12.java
index 4d9db2d5b1..18ca4a6d0f 100644
---
a/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/FetchAzureBlobStorage_v12.java
+++
b/nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/processors/azure/storage/FetchAzureBlobStorage_v12.java
@@ -20,11 +20,20 @@ import com.azure.storage.blob.BlobClient;
import com.azure.storage.blob.BlobContainerClient;
import com.azure.storage.blob.BlobServiceClient;
import com.azure.storage.blob.models.BlobRange;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.TimeUnit;
import org.apache.nifi.annotation.behavior.InputRequirement;
import org.apache.nifi.annotation.behavior.InputRequirement.Requirement;
import org.apache.nifi.annotation.behavior.WritesAttribute;
import org.apache.nifi.annotation.behavior.WritesAttributes;
import org.apache.nifi.annotation.documentation.CapabilityDescription;
+import org.apache.nifi.annotation.documentation.MultiProcessorUseCase;
+import org.apache.nifi.annotation.documentation.ProcessorConfiguration;
import org.apache.nifi.annotation.documentation.SeeAlso;
import org.apache.nifi.annotation.documentation.Tags;
import org.apache.nifi.components.PropertyDescriptor;
@@ -40,15 +49,6 @@ import org.apache.nifi.processor.util.StandardValidators;
import org.apache.nifi.processors.azure.AbstractAzureBlobProcessor_v12;
import org.apache.nifi.processors.azure.ClientSideEncryptionSupport;
import org.apache.nifi.processors.azure.storage.utils.AzureStorageUtils;
-
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Collection;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
-import java.util.concurrent.TimeUnit;
-
import static
org.apache.nifi.processors.azure.storage.utils.BlobAttributes.ATTR_DESCRIPTION_BLOBNAME;
import static
org.apache.nifi.processors.azure.storage.utils.BlobAttributes.ATTR_DESCRIPTION_BLOBTYPE;
import static
org.apache.nifi.processors.azure.storage.utils.BlobAttributes.ATTR_DESCRIPTION_CONTAINER;
@@ -81,6 +81,32 @@ import static
org.apache.nifi.processors.azure.storage.utils.BlobAttributes.ATTR
@WritesAttribute(attribute = ATTR_NAME_LANG, description =
ATTR_DESCRIPTION_LANG),
@WritesAttribute(attribute = ATTR_NAME_TIMESTAMP, description =
ATTR_DESCRIPTION_TIMESTAMP),
@WritesAttribute(attribute = ATTR_NAME_LENGTH, description =
ATTR_DESCRIPTION_LENGTH)})
+@MultiProcessorUseCase(
+description = "Retrieve all files in an Azure Blob Storage container",
+keywords = {"azure", "blob", "storage", "state", "retrieve", "fetch",
"all", "stream"},
+configurations = {
+@ProcessorConfiguration(
+processorClass = ListAzureBlobStorage_v12.class,
+configuration = """
+The "Container Name" property should be set to the name of the
Blob Storage Container that files reside in. \
+If the flow being built is to be reused elsewhere, it's a
good idea to parameterize this property by setting it to something
