From a14dbc7dbe20d31e919d52e349efbabc73caf19f Mon Sep 17 00:00:00 2001 From: patricker Date: Fri, 29 Jun 2018 08:33:51 -0600 Subject: [PATCH] NIFI-5339 - Better Time Tracking for ExecuteSQL Durations Signed-off-by: Pierre Villard This closes #2824. --- .../java/org/apache/nifi/processors/standard/ExecuteSQL.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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 af22fc3ecb27..66c23389f049 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 @@ }) @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.") })