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 <[email protected]>
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 <[email protected]>
---
.../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.")
