Repository: nifi Updated Branches: refs/heads/master c1083dfb6 -> a14dbc7db
NIFI-5339 - Better Time Tracking for ExecuteSQL Durations Signed-off-by: Pierre Villard <[email protected]> This closes #2824. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/a14dbc7d Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/a14dbc7d Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/a14dbc7d Branch: refs/heads/master Commit: a14dbc7dbe20d31e919d52e349efbabc73caf19f Parents: c1083df Author: patricker <[email protected]> Authored: Fri Jun 29 08:33:51 2018 -0600 Committer: Pierre Villard <[email protected]> Committed: Fri Jun 29 16:47:55 2018 +0200 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/standard/ExecuteSQL.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/a14dbc7d/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 af22fc3..66c2338 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 @@ -92,7 +92,9 @@ import static org.apache.nifi.processors.standard.util.JdbcCommon.USE_AVRO_LOGIC }) @WritesAttributes({ @WritesAttribute(attribute="executesql.row.count", description = "Contains the number of rows returned in the select query"), - @WritesAttribute(attribute="executesql.query.duration", description = "Duration of the query in milliseconds"), + @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.resultset.index", description = "Assuming multiple result sets are returned, " + "the zero based index of this result set.") })
