private MetricsChartDataVO getCPUTime()

in backend/src/main/java/org/apache/iotdb/admin/service/impl/IotDBServiceImpl.java [3722:3804]
49 lines of code
2 McCabe index (conditional complexity)

  private MetricsChartDataVO getCPUTime(
      SessionPool sessionPool,
      SessionDataSetWrapper sessionDataSetWrapper,
      String url,
      Integer port) {
    // TODO：【接口缺失，等待确认增加】
    List<String> timeList = new ArrayList<>();
    List<String> metricnameList = new ArrayList<>();
    metricnameList.add("模块1");
    metricnameList.add("模块2");
    metricnameList.add("模块3");
    metricnameList.add("模块4");
    metricnameList.add("模块5");
    List<String> unitList = new ArrayList<>();
    unitList.add("%");
    List<String> module1 = new ArrayList<>();
    List<String> module2 = new ArrayList<>();
    List<String> module3 = new ArrayList<>();
    List<String> module4 = new ArrayList<>();
    List<String> module5 = new ArrayList<>();
    HashMap<String, List<String>> dataList = new HashMap<>();
    if (port == 6668) {
      port = 8086;
    }
    String sql =
        "select * from "
            + "root._metric.\"127.0.0.1:"
            + port
            + "\".\"jvm.threads.daemon\", "
            + "root._metric.\"127.0.0.1:"
            + port
            + "\".\"jvm.threads.live\" "
            + "order by time desc limit 1";
    MetricsChartDataVO metricsChartDataVO = new MetricsChartDataVO();
    //      try {
    //        sessionDataSetWrapper = sessionPool.executeQueryStatement(sql);
    //        int batchSize = sessionDataSetWrapper.getBatchSize();
    //        if (batchSize > 0) {
    //          int count = 0;
    //          while (sessionDataSetWrapper.hasNext()) {
    //            count++;
    //            RowRecord rowRecord = sessionDataSetWrapper.next();
    //            long timestamp = rowRecord.getTimestamp();
    //            List<org.apache.iotdb.tsfile.read.common.Field> fields1 = rowRecord.getFields();
    //            String pattern1 = "HH:mm";
    //            SimpleDateFormat simpleDateFormat1 = new SimpleDateFormat(pattern1);
    //            timeList.add(simpleDateFormat1.format(timestamp));
    //            String s1 = fields1.get(0).toString();
    //            end.add(s1.substring(0, s1.indexOf('.')));
    //            String s2 = fields1.get(1).toString();
    //            total.add(s2.substring(0, s2.indexOf('.')));
    //            front.add((Integer.parseInt(s2.substring(0,
    // s2.indexOf('.')))-Integer.parseInt(s1.substring(0, s1.indexOf('.')))) + "");
    //          }
    //          dataList.put(metricnameList.get(0), front);
    //          dataList.put(metricnameList.get(1), end);
    //          dataList.put(metricnameList.get(2), total);
    //          metricsChartDataVO.setTimeList(timeList);
    //          metricsChartDataVO.setMetricnameList(metricnameList);
    //          metricsChartDataVO.setDataList(dataList);
    //        }
    //      } catch (IoTDBConnectionException e) {
    //        e.printStackTrace();
    //      } catch (StatementExecutionException e) {
    //        e.printStackTrace();
    //      }
    module1.add("15" + "%");
    module2.add("25" + "%");
    module3.add("20" + "%");
    module4.add("30" + "%");
    module5.add("10" + "%");

    dataList.put(metricnameList.get(0), module1);
    dataList.put(metricnameList.get(1), module2);
    dataList.put(metricnameList.get(2), module3);
    dataList.put(metricnameList.get(3), module3);
    dataList.put(metricnameList.get(4), module3);
    metricsChartDataVO.setTimeList(timeList);
    metricsChartDataVO.setMetricnameList(metricnameList);
    metricsChartDataVO.setDataList(dataList);
    metricsChartDataVO.setUnitList(unitList);
    return metricsChartDataVO;
  }