test_class.file: storm/storm-benchmark/src/test/java/storm/benchmark/util/MetricsUtilsTest.java
test_class.identifier: MetricsUtilsTest
test_case.body: @Test
    public void testAddLatency() {
      Map<String, List<Double>> stats = Maps.newHashMap();
      String id = "spout";
      double lat = 0.01;
      MetricsUtils.addLatency(stats, id, lat);
      assertThat(stats).containsKey(id);
      assertThat(stats.get(id)).isNotNull().contains(lat);
    }
test_case.class_method_signature: MetricsUtilsTest.testAddLatency()
test_case.full_signature: @Test public void testAddLatency()
test_case.identifier: testAddLatency
test_case.invocations: newHashMap addLatency containsKey assertThat contains isNotNull assertThat get
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testAddLatency()
focal_class.declarator: MB = 1000 * 1000
focal_class.modifier: private static final
focal_class.original_string: private static final int MB = 1000 * 1000;
focal_class.type: int
focal_class.var_name: MB
focal_class.file: storm/storm-benchmark/src/main/java/storm/benchmark/util/MetricsUtils.java
focal_class.identifier: MetricsUtils
focal_class.class_method_signature: MetricsUtils.MetricsUtils()
focal_class.full_signature: private  MetricsUtils()
focal_class.identifier: MetricsUtils
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.signature:  MetricsUtils()
focal_class.class_method_signature: MetricsUtils.addLatency(Map<String, List<Double>> stats, String id, double lat)
focal_class.full_signature: public static void addLatency(Map<String, List<Double>> stats, String id, double lat)
focal_class.identifier: addLatency
focal_class.modifiers: public static
focal_class.parameters: (Map<String, List<Double>> stats, String id, double lat)
focal_class.return: void
focal_class.signature: void addLatency(Map<String, List<Double>> stats, String id, double lat)
focal_class.class_method_signature: MetricsUtils.getTopologySummary(ClusterSummary cs, String name)
focal_class.full_signature: public static TopologySummary getTopologySummary(ClusterSummary cs, String name)
focal_class.identifier: getTopologySummary
focal_class.modifiers: public static
focal_class.parameters: (ClusterSummary cs, String name)
focal_class.return: TopologySummary
focal_class.signature: TopologySummary getTopologySummary(ClusterSummary cs, String name)
focal_class.class_method_signature: MetricsUtils.getSpoutCompleteLatency(SpoutStats stats, String window, String stream)
focal_class.full_signature: public static double getSpoutCompleteLatency(SpoutStats stats, String window, String stream)
focal_class.identifier: getSpoutCompleteLatency
focal_class.modifiers: public static
focal_class.parameters: (SpoutStats stats, String window, String stream)
focal_class.return: double
focal_class.signature: double getSpoutCompleteLatency(SpoutStats stats, String window, String stream)
focal_class.class_method_signature: MetricsUtils.getSpoutAcked(SpoutStats stats, String window, String stream)
focal_class.full_signature: public static long getSpoutAcked(SpoutStats stats, String window, String stream)
focal_class.identifier: getSpoutAcked
focal_class.modifiers: public static
focal_class.parameters: (SpoutStats stats, String window, String stream)
focal_class.return: long
focal_class.signature: long getSpoutAcked(SpoutStats stats, String window, String stream)
focal_class.class_method_signature: MetricsUtils.getTransferred(ExecutorStats stats, String window, String stream)
focal_class.full_signature: public static long getTransferred(ExecutorStats stats, String window, String stream)
focal_class.identifier: getTransferred
focal_class.modifiers: public static
focal_class.parameters: (ExecutorStats stats, String window, String stream)
focal_class.return: long
focal_class.signature: long getTransferred(ExecutorStats stats, String window, String stream)
focal_class.class_method_signature: MetricsUtils.getThroughput(double throughputDiff, long timeDiff)
focal_class.full_signature: public static double getThroughput(double throughputDiff, long timeDiff)
focal_class.identifier: getThroughput
focal_class.modifiers: public static
focal_class.parameters: (double throughputDiff, long timeDiff)
focal_class.return: double
focal_class.signature: double getThroughput(double throughputDiff, long timeDiff)
focal_class.class_method_signature: MetricsUtils.getThroughputMB(double throughputDiff, long timeDiff, int msgSize)
focal_class.full_signature: public static double getThroughputMB(double throughputDiff, long timeDiff, int msgSize)
focal_class.identifier: getThroughputMB
focal_class.modifiers: public static
focal_class.parameters: (double throughputDiff, long timeDiff, int msgSize)
focal_class.return: double
focal_class.signature: double getThroughputMB(double throughputDiff, long timeDiff, int msgSize)
focal_method.body: public static void addLatency(Map<String, List<Double>> stats, String id, double lat) {
      List<Double> latList = stats.get(id);
      if (null == latList) {
        latList = new LinkedList<Double>();
        stats.put(id, latList);
      }
      latList.add(lat);
    }
focal_method.class_method_signature: MetricsUtils.addLatency(Map<String, List<Double>> stats, String id, double lat)
focal_method.full_signature: public static void addLatency(Map<String, List<Double>> stats, String id, double lat)
focal_method.identifier: addLatency
focal_method.invocations: get put add
focal_method.modifiers: public static
focal_method.parameters: (Map<String, List<Double>> stats, String id, double lat)
focal_method.return: void
focal_method.signature: void addLatency(Map<String, List<Double>> stats, String id, double lat)