You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2017/11/01 18:49:16 UTC
nifi git commit: NIFI-4552 Add mime.type and record.count Write
Attributes to QueryRecord doc
Repository: nifi
Updated Branches:
refs/heads/master 448f03eda -> 9a850c7ed
NIFI-4552 Add mime.type and record.count Write Attributes to QueryRecord doc
NIFI-4552 minor checkstyle violation
Signed-off-by: Matthew Burgess <ma...@apache.org>
This closes #2242
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/9a850c7e
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/9a850c7e
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/9a850c7e
Branch: refs/heads/master
Commit: 9a850c7ed221e99ab266e06810d068186b1d87d2
Parents: 448f03e
Author: Andrew Lim <an...@gmail.com>
Authored: Tue Oct 31 13:24:16 2017 -0400
Committer: Matthew Burgess <ma...@apache.org>
Committed: Wed Nov 1 14:49:02 2017 -0400
----------------------------------------------------------------------
.../java/org/apache/nifi/processors/standard/QueryRecord.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/9a850c7e/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java
index fdbb64d..3084b72 100644
--- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java
+++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java
@@ -53,6 +53,8 @@ import org.apache.nifi.annotation.behavior.InputRequirement;
import org.apache.nifi.annotation.behavior.InputRequirement.Requirement;
import org.apache.nifi.annotation.behavior.SideEffectFree;
import org.apache.nifi.annotation.behavior.SupportsBatching;
+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.Tags;
import org.apache.nifi.annotation.lifecycle.OnScheduled;
@@ -102,6 +104,10 @@ import org.apache.nifi.util.StopWatch;
@DynamicProperty(name = "The name of the relationship to route data to", value="A SQL SELECT statement that is used to determine what data should be routed to this "
+ "relationship.", supportsExpressionLanguage=true, description="Each user-defined property specifies a SQL SELECT statement to run over the data, with the data "
+ "that is selected being routed to the relationship whose name is the property name")
+@WritesAttributes({
+ @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 selected by the query")
+})
public class QueryRecord extends AbstractProcessor {
static final PropertyDescriptor RECORD_READER_FACTORY = new PropertyDescriptor.Builder()
.name("record-reader")