[nifi] branch main updated: NIFI-7982 Added tags to FlattenJSON processor Adding missing imports

[mt...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mthomsen 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 d5dc63d  NIFI-7982 Added tags to FlattenJSON processor Adding missing imports
d5dc63d is described below

commit d5dc63ded93220ced8e861de69a679868532f7d3
Author: r65535 <56...@users.noreply.github.com>
AuthorDate: Fri Nov 13 13:34:50 2020 +0000

    NIFI-7982 Added tags to FlattenJSON processor
    Adding missing imports
    
    This closes #4662
    
    Signed-off-by: Mike Thomsen <mt...@apache.org>
---
 .../java/org/apache/nifi/processors/standard/FlattenJson.java    | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FlattenJson.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FlattenJson.java
index 69b85b3..917f905 100644
--- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FlattenJson.java
+++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/FlattenJson.java
@@ -24,6 +24,10 @@ import org.apache.commons.text.StringEscapeUtils;
 import org.apache.nifi.annotation.behavior.SideEffectFree;
 import org.apache.nifi.annotation.documentation.CapabilityDescription;
 import org.apache.nifi.annotation.documentation.Tags;
+import org.apache.nifi.annotation.behavior.EventDriven;
+import org.apache.nifi.annotation.behavior.InputRequirement;
+import org.apache.nifi.annotation.behavior.InputRequirement.Requirement;
+import org.apache.nifi.annotation.behavior.SupportsBatching;
 import org.apache.nifi.components.AllowableValue;
 import org.apache.nifi.components.PropertyDescriptor;
 import org.apache.nifi.components.ValidationResult;
@@ -46,6 +50,10 @@ import java.util.List;
 import java.util.Map;
 import java.util.Set;
 
+@EventDriven
+@SupportsBatching
+@InputRequirement(Requirement.INPUT_REQUIRED)
+@SideEffectFree
 @Tags({"json", "flatten"})
 @CapabilityDescription(
         "Provides the user with the ability to take a nested JSON document and flatten it into a simple key/value pair " +
@@ -53,7 +61,6 @@ import java.util.Set;
                 "Support three kinds of flatten mode, normal, keep-arrays and dot notation for MongoDB query. " +
                 "Default flatten mode is 'keep-arrays'."
 )
-@SideEffectFree
 public class FlattenJson extends AbstractProcessor {
     static final Relationship REL_SUCCESS = new Relationship.Builder()
             .description("Successfully flattened files go to this relationship.")