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 bad5c11109411314bd58d7fc6e31812c76262aef 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 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);
