Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-8126: Updated verbiage for ConnectionStatusDescriptors, added an Average Queued Duration 

This closes #4780.
This commit is contained in:
Mark Payne 2021-05-18 17:07:12 -04:00
parent 2309d75d3d
commit 1f0425b86d
1 changed files with 17 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/status/history/ConnectionStatusDescriptor.java
View File

@ -64,18 +64,25 @@ public enum ConnectionStatusDescriptor {
s -> Long.valueOf(s.getQueuedCount())),
TOTAL_QUEUED_DURATION(
"totalQueuedDuration",
"Total Queued Duration (5 mins)",
"The cumulative queued duration, in milliseconds, of all FlowFiles that were transferred to this Connection in the past 5 minutes",
Formatter.COUNT,
s -> Long.valueOf(s.getTotalQueuedDuration())),
"totalQueuedDuration",
"Total Queued Duration (millis)",
"The sum of the amount of time that all FlowFiles in the Connection have been in the queue",
Formatter.COUNT,
ConnectionStatus::getTotalQueuedDuration),
MAX_QUEUED_DURATION(
"maxQueuedDuration",
"Max Queued Duration (5 mins)",
"The max queued duration, in milliseconds, of any FlowFile that was transferred to this Connection in the past 5 minutes",
Formatter.COUNT,
s -> Long.valueOf(s.getMaxQueuedDuration()));
"maxQueuedDuration",
"Max Queued Duration (hr:min:sec)",
"The maximum amount of time that any FlowFile currently in this Connection has been in the queue",
Formatter.DURATION,
ConnectionStatus::getMaxQueuedDuration),
AVERAGE_QUEUED_DURATION(
"averageQueuedDuration",
"Average Queued Duration (hr:min:sec)",
"The average amount of time that each FlowFile currently in the Connection has been in the queue",
Formatter.DURATION,
s -> s.getQueuedCount() == 0 ? 0L : s.getTotalQueuedDuration() / s.getQueuedCount());
private MetricDescriptor<ConnectionStatus> descriptor;