From 8b3f6fa61c3eaa297f2ba8d44337f659c7c6f0e5 Mon Sep 17 00:00:00 2001 From: Matthew Burgess Date: Mon, 16 Dec 2019 14:03:56 -0500 Subject: [PATCH] NIFI-6953: Add missing documentation for input.flowfile.uuid attribute of ExecuteSQL processors --- .../java/org/apache/nifi/processors/standard/ExecuteSQL.java | 4 +++- .../org/apache/nifi/processors/standard/ExecuteSQLRecord.java | 2 ++ 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteSQL.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteSQL.java index 03010bb355..240075fbfe 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteSQL.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteSQL.java @@ -98,7 +98,9 @@ import static org.apache.nifi.util.db.AvroUtil.CodecType; @WritesAttribute(attribute = "fragment.index", description = "If 'Max Rows Per Flow File' is set then the position of this FlowFile in the list of " + "outgoing FlowFiles that were all derived from the same result set FlowFile. This can be " + "used in conjunction with the fragment.identifier attribute to know which FlowFiles originated from the same query result set and in what order " - + "FlowFiles were produced") + + "FlowFiles were produced"), + @WritesAttribute(attribute = "input.flowfile.uuid", description = "If the processor has an incoming connection, outgoing FlowFiles will have this attribute " + + "set to the value of the input FlowFile's UUID. If there is no incoming connection, the attribute will not be added.") }) public class ExecuteSQL extends AbstractExecuteSQL { diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteSQLRecord.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteSQLRecord.java index c9d80eb791..3e3dbea097 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteSQLRecord.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteSQLRecord.java @@ -92,6 +92,8 @@ import static org.apache.nifi.processors.standard.util.JdbcProperties.USE_AVRO_L + "outgoing FlowFiles that were all derived from the same result set FlowFile. This can be " + "used in conjunction with the fragment.identifier attribute to know which FlowFiles originated from the same query result set and in what order " + "FlowFiles were produced"), + @WritesAttribute(attribute = "input.flowfile.uuid", description = "If the processor has an incoming connection, outgoing FlowFiles will have this attribute " + + "set to the value of the input FlowFile's UUID. If there is no incoming connection, the attribute will not be added."), @WritesAttribute(attribute = "mime.type", description = "Sets the mime.type attribute to the MIME Type specified by the Record Writer."), @WritesAttribute(attribute = "record.count", description = "The number of records output by the Record Writer.") })