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 03775622b9835d6c62b7da9e9fccc328a88e428f Author: Yolanda Davis <[email protected]> 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 34c49c0..10ff3af 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 @@ -1186,6 +1186,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()))); @@ -1193,6 +1196,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);
