From d358c0f4f7631420d027b251617bcdab656f68ea Mon Sep 17 00:00:00 2001 From: qiubo Date: Fri, 9 Sep 2022 10:22:26 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8DES=20total=20=E6=9F=A5?= =?UTF-8?q?=E8=AF=A2=E8=BD=AC=E6=8D=A2=E5=BC=82=E5=B8=B8=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../streaming/km/persistence/es/dao/BaseMetricESDAO.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java b/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java index fe04e4d1..38f7764e 100644 --- a/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java +++ b/km-persistence/src/main/java/com/xiaojukeji/know/streaming/km/persistence/es/dao/BaseMetricESDAO.java @@ -336,7 +336,10 @@ public class BaseMetricESDAO extends BaseESDAO { if(null == response || null == response.getHits() || null ==response.getHits().getUnusedMap()){return -1;} - return Integer.valueOf(response.getHits().getUnusedMap().getOrDefault(TOTAL, 0).toString()); + // "total" : {"value": 123 , "relation": "XX "} + JSONObject jsonObjectTotal = (JSONObject) response.getHits().getUnusedMap().getOrDefault(TOTAL, 0); + + return Integer.valueOf(jsonObjectTotal.get(VALUE).toString()); } protected T filterMetrics(T t, List metricNames){