Github user mattyb149 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/877#discussion_r75051737
--- Diff:
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryDatabaseTable.java
---
@@ -75,10 +66,19 @@
+ "to fetch only those records that have max values greater than
the retained values. This can be used for "
+ "incremental fetching, fetching of newly added rows, etc. To
clear the maximum values, clear the state of the processor "
+ "per the State Management documentation")
-@WritesAttribute(attribute = "querydbtable.row.count")
+@WritesAttributes({
+ @WritesAttribute(attribute = "querydbtable.row.count"),
+ @WritesAttribute(attribute="fragment.identifier", description="If
'Max Rows in Flow File' is set then all FlowFiles from the same query result
set "
+ + "will have the same value for the fragment.identifier
attribute. This can then be used to correlate the results."),
+ @WritesAttribute(attribute="fragment.index", description="If 'Max
Rows in 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")})
+@DynamicProperty(name = "Initial Max Value", value = "Attribute Expression
Language", supportsExpressionLanguage = false, description = "Specifies an
initial "
--- End diff --
This is excellent use of documentation!
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
