NIFI-5339 - Better Time Tracking for ExecuteSQL Durations

Signed-off-by: Pierre Villard <[email protected]> This closes apache#2824.
davyam · Jun 29, 2018 · a14dbc7 · a14dbc7
1 parent c1083df
commit a14dbc7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...ifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteSQL.java b/...ifi-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.")
 })