gfwleak/galaxy-tsg-olap-generate-baseline
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改KF参数

Browse Source
This commit is contained in:
yinjiangyi
2021-08-06 09:32:59 +08:00
parent b4957aa33f
commit 2f884c19d4
3 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/cn/mesalab/dao/ReadHistoricalDruidData.java
View File

@@ -42,14 +42,15 @@ public class ReadHistoricalDruidData implements Callable<Map<String, List<Map<St
resultData.putAll(readFromDruid); resultData.putAll(readFromDruid);
long end = System.currentTimeMillis(); 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(); connection.close();
stat.close(); stat.close();
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
} finally { } finally {
countDownLatch.countDown(); countDownLatch.countDown();
LOG.info("本线程读取完毕，剩余线程数量：" + countDownLatch.getCount());
} }
return resultData; return resultData;
} }

6
src/main/java/cn/mesalab/service/BaselineSingleThread.java
View File

@@ -95,13 +95,13 @@ public class BaselineSingleThread extends Thread {
Arrays.fill(baselineArr, (int)percentile); Arrays.fill(baselineArr, (int)percentile);
// KF // KF
baselineArr = baselineFunction(series); 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 { } else {
// 判断周期性 // 判断周期性
if (SeriesUtils.isPeriod(series)){ if (SeriesUtils.isPeriod(series)){
// KF // KF
baselineArr = baselineFunction(series); 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 { } else {
// 百分位数 // 百分位数
int ipPercentile = SeriesUtils.percentile( 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()), Integer.valueOf(i.get(ApplicationConfig.BASELINE_METRIC_TYPE).toString())).collect(Collectors.toList()),
ApplicationConfig.BASELINE_RATIONAL_PERCENTILE); ApplicationConfig.BASELINE_RATIONAL_PERCENTILE);
Arrays.fill(baselineArr, ipPercentile); 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));
} }
} }

2
src/main/java/cn/mesalab/service/algorithm/KalmanFilter.java
View File

@@ -72,7 +72,7 @@ public class KalmanFilter {
forecastSeries.add((int)sum/partitonNum); 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);
} }