docs: public Map<AnalysisType, ThroughputInfo> listRealtimeThroughput(RealtimeThroughputCondition condition) {
          Assert.assertNotNull(condition);
          Map<AnalysisType, ThroughputInfo> throughputInfos = new HashMap<AnalysisType, ThroughputInfo>();
          TimelineThroughputCondition timelineCondition = new TimelineThroughputCondition();
          Date realtime = new Date(System.currentTimeMillis());
          timelineCondition.setPipelineId(condition.getPipelineId());
          timelineCondition.setType(condition.getType());
          timelineCondition.setStart(new Date(realtime.getTime() - condition.getMax() * 60 * 1000));
          timelineCondition.setEnd(realtime);
          List<ThroughputStatDO> throughputStatDOs = throughputDao.listTimelineThroughputStat(timelineCondition);
          for (AnalysisType analysisType : condition.getAnalysisType()) {
              ThroughputInfo throughputInfo = new ThroughputInfo();
              List<ThroughputStat> throughputStat = new ArrayList<ThroughputStat>();
              for (ThroughputStatDO throughputStatDO : throughputStatDOs) {
                  if (realtime.getTime() - throughputStatDO.getEndTime().getTime() <= analysisType.getValue() * 60 * 1000) {
                      throughputStat.add(throughputStatDOToModel(throughputStatDO));
                  }
              }
              throughputInfo.setItems(throughputStat);
              throughputInfo.setSeconds(analysisType.getValue() * 60L);
              throughputInfos.put(analysisType, throughputInfo);
          }
          return throughputInfos;
  
      }