You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ai...@apache.org on 2019/08/19 13:53:49 UTC
[nifi] 13/21: NIFI-6510 Add prediction percent values and predicted
interval seconds
This is an automated email from the ASF dual-hosted git repository.
aichrist pushed a commit to branch analytics-framework
in repository https://gitbox.apache.org/repos/asf/nifi.git
commit 8a48c779d1e7c63caf404103851ccdff72246a7c
Author: Yolanda Davis <yo...@gmail.com>
AuthorDate: Mon Jul 29 08:21:29 2019 -0400
NIFI-6510 Add prediction percent values and predicted interval seconds
(cherry picked from commit e60015d)
---
.../src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java
index e56e99a..32de8dc 100644
--- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java
+++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/dto/DtoFactory.java
@@ -1184,6 +1184,9 @@ public final class DtoFactory {
snapshot.setPredictionIntervalSeconds(((Long) (connectionStatus.getPredictionIntervalMillis() / 1000L)).intValue());
snapshot.setPredictedMillisUntilCountBackpressure(connectionStatus.getPredictedTimeToCountBackpressureMillis());
snapshot.setPredictedCountAtNextInterval(connectionStatus.getNextPredictedQueuedCount());
+ snapshot.setPredictedPercentCount(connectionStatus.getPredictedPercentCount());
+ snapshot.setPredictedPercentBytes(connectionStatus.getPredictedPercentBytes());
+ snapshot.setPredictionIntervalSeconds(((Long)(connectionStatus.getPredictionIntervalMillis() / 1000L)).intValue());
}
if (connectionStatus.getBackPressureBytesThreshold() > 0) {
snapshot.setPercentUseBytes(Math.min(100, StatusMerger.getUtilization(connectionStatus.getQueuedBytes(), connectionStatus.getBackPressureBytesThreshold())));
@@ -1191,6 +1194,9 @@ public final class DtoFactory {
snapshot.setPredictionIntervalSeconds(((Long) (connectionStatus.getPredictionIntervalMillis() / 1000L)).intValue());
snapshot.setPredictedMillisUntilBytesBackpressure(connectionStatus.getPredictedTimeToBytesBackpressureMillis());
snapshot.setPredictedBytesAtNextInterval(connectionStatus.getNextPredictedQueuedBytes());
+ snapshot.setPredictedPercentCount(connectionStatus.getPredictedPercentCount());
+ snapshot.setPredictedPercentBytes(connectionStatus.getPredictedPercentBytes());
+ snapshot.setPredictionIntervalSeconds(((Long)(connectionStatus.getPredictionIntervalMillis() / 1000L)).intValue());
}
StatusMerger.updatePrettyPrintedFields(snapshot);