code: public static TopologyExecutionCount convertToTotalCount(TopologyInfo topologyInfo)
      {
          List<ExecutorSummary> executors = topologyInfo.get_executors();
          TopologyExecutionCount totalCount = new TopologyExecutionCount();
  
          for (ExecutorSummary summary : executors)
          {
              ExecutorStats stats = summary.get_stats();
  
              Map<String, Map<String, Long>> emitStats = stats.get_emitted();
              long emitted = extractAllDefaultValue(emitStats);
              Map<String, Map<String, Long>> transferStats = stats.get_transferred();
              long transferred = extractAllDefaultValue(transferStats);
  
              long acked = 0;
              long failed = 0;
  
              ExecutorSpecificStats specificStats = stats.get_specific();
  
              if (specificStats.is_set_spout() == true)
              {
                  SpoutStats spoutStats = specificStats.get_spout();
                  Map<String, Map<String, Long>> ackStats = spoutStats.get_acked();
                  acked = extractAllDefaultValue(ackStats);
                  Map<String, Map<String, Long>> failStats = spoutStats.get_failed();
                  failed = extractAllDefaultValue(failStats);
              }
  
              // 取得した値をエンティティに加算する。
              totalCount.setEmitted(totalCount.getEmitted() + emitted);
              totalCount.setTransferred(totalCount.getTransferred() + transferred);
              totalCount.setAcked(totalCount.getAcked() + acked);
              totalCount.setFailed(totalCount.getFailed() + failed);
          }
  
          return totalCount;
      }
docs: トポロジ情報を基に処理カウントエンティティに変換する。
  
  @param topologyInfo トポロジ情報
  @return 処理カウントエンティティ