Repository: nifi Updated Branches: refs/heads/master 023f0c41c -> 54402a1ec
NIFI-5828: Documents behavior of ExecuteSQL attrs when Max Rows Per Flow File is enabled This closes #3177. Signed-off-by: Koji Kawamura <ijokaruma...@apache.org> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/54402a1e Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/54402a1e Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/54402a1e Branch: refs/heads/master Commit: 54402a1ecda4b11ca10472fada9adce484b031c1 Parents: 023f0c4 Author: Colin Dean <colin.d...@arcadia.io> Authored: Sun Nov 18 23:14:55 2018 -0500 Committer: Koji Kawamura <ijokaruma...@apache.org> Committed: Mon Nov 19 14:18:31 2018 +0900 ---------------------------------------------------------------------- .../org/apache/nifi/processors/standard/ExecuteSQL.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/54402a1e/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteSQL.java ---------------------------------------------------------------------- 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 9c61793..99e0d2a 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 @@ -77,10 +77,14 @@ import static org.apache.nifi.processors.standard.util.JdbcCommon.USE_AVRO_LOGIC + "'yyyy-MM-dd HH:mm:ss.SSS' for Timestamp is used.") }) @WritesAttributes({ - @WritesAttribute(attribute = "executesql.row.count", description = "Contains the number of rows returned in the select query"), - @WritesAttribute(attribute = "executesql.query.duration", description = "Combined duration of the query execution time and fetch time in milliseconds"), - @WritesAttribute(attribute = "executesql.query.executiontime", description = "Duration of the query execution time in milliseconds"), - @WritesAttribute(attribute = "executesql.query.fetchtime", description = "Duration of the result set fetch time in milliseconds"), + @WritesAttribute(attribute = "executesql.row.count", description = "Contains the number of rows returned by the query. " + + "If 'Max Rows Per Flow File' is set, then this number will reflect the number of rows in the Flow File instead of the entire result set."), + @WritesAttribute(attribute = "executesql.query.duration", description = "Combined duration of the query execution time and fetch time in milliseconds. " + + "If 'Max Rows Per Flow File' is set, then this number will reflect only the fetch time for the rows in the Flow File instead of the entire result set."), + @WritesAttribute(attribute = "executesql.query.executiontime", description = "Duration of the query execution time in milliseconds. " + + "This number will reflect the query execution time regardless of the 'Max Rows Per Flow File' setting."), + @WritesAttribute(attribute = "executesql.query.fetchtime", description = "Duration of the result set fetch time in milliseconds. " + + "If 'Max Rows Per Flow File' is set, then this number will reflect only the fetch time for the rows in the Flow File instead of the entire result set."), @WritesAttribute(attribute = "executesql.resultset.index", description = "Assuming multiple result sets are returned, " + "the zero based index of this result set."), @WritesAttribute(attribute = "fragment.identifier", description = "If 'Max Rows Per Flow File' is set then all FlowFiles from the same query result set "
