nifi git commit: NIFI-4560 Added mime.type and record.count Write Attributes to ValidateRecord doc

[pv...@apache.org]

Repository: nifi
Updated Branches:
  refs/heads/master 2a69b35f1 -> b5d7aecfa


NIFI-4560 Added mime.type and record.count Write Attributes to ValidateRecord doc

Signed-off-by: Pierre Villard <pi...@gmail.com>

This closes #2249.


Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/b5d7aecf
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/b5d7aecf
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/b5d7aecf

Branch: refs/heads/master
Commit: b5d7aecfac6b5f4424b3bc775c1477281f599846
Parents: 2a69b35
Author: Andrew Lim <an...@gmail.com>
Authored: Thu Nov 2 23:53:05 2017 -0400
Committer: Pierre Villard <pi...@gmail.com>
Committed: Fri Nov 3 11:10:00 2017 +0100

----------------------------------------------------------------------
 .../org/apache/nifi/processors/standard/ValidateRecord.java  | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/nifi/blob/b5d7aecf/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ValidateRecord.java
----------------------------------------------------------------------
diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ValidateRecord.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ValidateRecord.java
index 646db88..5dbc305 100644
--- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ValidateRecord.java
+++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ValidateRecord.java
@@ -38,6 +38,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.avro.AvroSchemaValidator;
@@ -78,10 +80,14 @@ import org.apache.nifi.serialization.record.validation.ValidationError;
 @InputRequirement(Requirement.INPUT_REQUIRED)
 @Tags({"record", "schema", "validate"})
 @CapabilityDescription("Validates the Records of an incoming FlowFile against a given schema. All records that adhere to the schema are routed to the \"valid\" relationship while "
-    + "records that do not adhere to hte schema are routed to the \"invalid\" relationship. It is therefore possible for a single incoming FlowFile to be split into two individual "
+    + "records that do not adhere to the schema are routed to the \"invalid\" relationship. It is therefore possible for a single incoming FlowFile to be split into two individual "
     + "FlowFiles if some records are valid according to the schema and others are not. Any FlowFile that is routed to the \"invalid\" relationship will emit a ROUTE Provenance Event "
     + "with the Details field populated to explain why records were invalid. In addition, to gain further explanation of why records were invalid, DEBUG-level logging can be enabled "
     + "for the \"org.apache.nifi.processors.standard.ValidateRecord\" logger.")
+@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 in the FlowFile routed to a relationship")
+})
 public class ValidateRecord extends AbstractProcessor {
 
     static final AllowableValue SCHEMA_NAME_PROPERTY = new AllowableValue("schema-name-property", "Use Schema Name Property",