From 2f884c19d4da341addade93235d7e7a749420fca Mon Sep 17 00:00:00 2001
From: yinjiangyi <yinjiangyi1996@gmail.com>
Date: Fri, 6 Aug 2021 09:32:59 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9KF=E5=8F=82=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/cn/mesalab/dao/ReadHistoricalDruidData.java   | 5 +++--
 src/main/java/cn/mesalab/service/BaselineSingleThread.java  | 6 +++---
 .../java/cn/mesalab/service/algorithm/KalmanFilter.java     | 2 +-
 3 files changed, 7 insertions(+), 6 deletions(-)

diff --git a/src/main/java/cn/mesalab/dao/ReadHistoricalDruidData.java b/src/main/java/cn/mesalab/dao/ReadHistoricalDruidData.java
index 28e113d..d97dcff 100644
--- a/src/main/java/cn/mesalab/dao/ReadHistoricalDruidData.java
+++ b/src/main/java/cn/mesalab/dao/ReadHistoricalDruidData.java
@@ -42,14 +42,15 @@ public class ReadHistoricalDruidData implements Callable<Map<String, List<Map<St
             resultData.putAll(readFromDruid);
 
             long end = System.currentTimeMillis();
-            LOG.info("\n获取" + resultData.size() + " Server IP数据，运行时间：" + (end - start));
+            LOG.info("获取Server IP：" + resultData.size() +
+                    "   运行时间：" + (end - start) +
+                    "   剩余线程数量：" + countDownLatch.getCount()) ;
             connection.close();
             stat.close();
         } catch (Exception e) {
             e.printStackTrace();
         } finally {
             countDownLatch.countDown();
-            LOG.info("本线程读取完毕，剩余线程数量：" + countDownLatch.getCount());
         }
         return resultData;
     }
diff --git a/src/main/java/cn/mesalab/service/BaselineSingleThread.java b/src/main/java/cn/mesalab/service/BaselineSingleThread.java
index 485baf6..ab749d5 100644
--- a/src/main/java/cn/mesalab/service/BaselineSingleThread.java
+++ b/src/main/java/cn/mesalab/service/BaselineSingleThread.java
@@ -95,13 +95,13 @@ public class BaselineSingleThread extends Thread {
             Arrays.fill(baselineArr, (int)percentile);
             // KF
             baselineArr = baselineFunction(series);
-            System.out.println("高频IP:" + ip + " origin:" + series + "\n baseline:" + Arrays.toString(baselineArr));
+            // System.out.println("高频IP:" + ip + " origin:" + series + "\n baseline:" + Arrays.toString(baselineArr));
         } else {
             // 判断周期性
             if (SeriesUtils.isPeriod(series)){
                 // KF
                 baselineArr = baselineFunction(series);
-                System.out.println("低频周期IP:" + ip + " origin:" + series + "\n baseline:" + Arrays.toString(baselineArr));
+                // System.out.println("低频周期IP:" + ip + " origin:" + series + "\n baseline:" + Arrays.toString(baselineArr));
             } else {
                 // 百分位数
                 int ipPercentile = SeriesUtils.percentile(
@@ -109,7 +109,7 @@ public class BaselineSingleThread extends Thread {
                                 Integer.valueOf(i.get(ApplicationConfig.BASELINE_METRIC_TYPE).toString())).collect(Collectors.toList()),
                         ApplicationConfig.BASELINE_RATIONAL_PERCENTILE);
                 Arrays.fill(baselineArr, ipPercentile);
-                System.out.println("其他IP:" + ip + " origin:" + series + "\n baseline:" + Arrays.toString(baselineArr));
+                // System.out.println("其他IP:" + ip + " origin:" + series + "\n baseline:" + Arrays.toString(baselineArr));
             }
         }
 
diff --git a/src/main/java/cn/mesalab/service/algorithm/KalmanFilter.java b/src/main/java/cn/mesalab/service/algorithm/KalmanFilter.java
index 32cc622..029cb94 100644
--- a/src/main/java/cn/mesalab/service/algorithm/KalmanFilter.java
+++ b/src/main/java/cn/mesalab/service/algorithm/KalmanFilter.java
@@ -72,7 +72,7 @@ public class KalmanFilter {
             forecastSeries.add((int)sum/partitonNum);
         }
 
-        System.out.println("KF test: origin:" + historicalSeries + "\n smooth:" + smoothSeries + "\n baseline:" + forecastSeries);
+        //System.out.println("KF test: origin:" + historicalSeries + "\n smooth:" + smoothSeries + "\n baseline:" + forecastSeries);
 
     }