diff options
author | Øyvind Grønnesby <oyving@verizonmedia.com> | 2020-11-17 10:32:08 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-11-17 10:32:08 +0100 |
commit | 770c0f039885e61a71f543ddbf4da1b131a8a7eb (patch) | |
tree | f414af7eda2414aab94df6461af8d710ede61820 | |
parent | b4dc184e1e22ac91b6aa6f7be53808782142d2d2 (diff) | |
parent | 1355fb48398eff02bea7eb12c46b22d68cd8c73c (diff) |
Merge pull request #15361 from vespa-engine/ogronnesby/remove-use-of-stream
Remove unnecessary use of .stream()
-rw-r--r-- | controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/application/ApplicationApiHandler.java | 50 |
1 files changed, 23 insertions, 27 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/application/ApplicationApiHandler.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/application/ApplicationApiHandler.java index 0f9d3e181b4..1c0dca26f5a 100644 --- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/application/ApplicationApiHandler.java +++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/restapi/application/ApplicationApiHandler.java @@ -1353,33 +1353,29 @@ public class ApplicationApiHandler extends LoggingRequestHandler { Cursor detailsMem = details.setObject("mem"); Cursor detailsDisk = details.setObject("disk"); - history.entrySet().stream() - .forEach(entry -> { - String instanceName = entry.getKey().instance().value(); - Cursor detailsCpuApp = detailsCpu.setObject(instanceName); - Cursor detailsMemApp = detailsMem.setObject(instanceName); - Cursor detailsDiskApp = detailsDisk.setObject(instanceName); - Cursor detailsCpuData = detailsCpuApp.setArray("data"); - Cursor detailsMemData = detailsMemApp.setArray("data"); - Cursor detailsDiskData = detailsDiskApp.setArray("data"); - entry.getValue().stream() - .forEach(resourceSnapshot -> { - - Cursor cpu = detailsCpuData.addObject(); - cpu.setLong("unixms", resourceSnapshot.getTimestamp().toEpochMilli()); - cpu.setDouble("value", resourceSnapshot.getCpuCores()); - - Cursor mem = detailsMemData.addObject(); - mem.setLong("unixms", resourceSnapshot.getTimestamp().toEpochMilli()); - mem.setDouble("value", resourceSnapshot.getMemoryGb()); - - Cursor disk = detailsDiskData.addObject(); - disk.setLong("unixms", resourceSnapshot.getTimestamp().toEpochMilli()); - disk.setDouble("value", resourceSnapshot.getDiskGb()); - - }); - - }); + history.forEach((applicationId, resources) -> { + String instanceName = applicationId.instance().value(); + Cursor detailsCpuApp = detailsCpu.setObject(instanceName); + Cursor detailsMemApp = detailsMem.setObject(instanceName); + Cursor detailsDiskApp = detailsDisk.setObject(instanceName); + Cursor detailsCpuData = detailsCpuApp.setArray("data"); + Cursor detailsMemData = detailsMemApp.setArray("data"); + Cursor detailsDiskData = detailsDiskApp.setArray("data"); + + resources.forEach(resourceSnapshot -> { + Cursor cpu = detailsCpuData.addObject(); + cpu.setLong("unixms", resourceSnapshot.getTimestamp().toEpochMilli()); + cpu.setDouble("value", resourceSnapshot.getCpuCores()); + + Cursor mem = detailsMemData.addObject(); + mem.setLong("unixms", resourceSnapshot.getTimestamp().toEpochMilli()); + mem.setDouble("value", resourceSnapshot.getMemoryGb()); + + Cursor disk = detailsDiskData.addObject(); + disk.setLong("unixms", resourceSnapshot.getTimestamp().toEpochMilli()); + disk.setDouble("value", resourceSnapshot.getDiskGb()); + }); + }); return new SlimeJsonResponse(slime); } |