Github user mattyb149 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/877#discussion_r75120131
--- Diff:
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryDatabaseTable.java
---
@@ -75,10 +71,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 Per Flow File' is set then all FlowFiles from the same query result
set "
--- End diff --
I think fragment.count could be pretty useful here, in case the records may
be re-joined, aggregated, etc. down the line.
---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
