class StormBenchmark implements IBenchmark {

  @Override
  public IMetricsCollector getMetricsCollector(Config config, StormTopology topology) {

    Set<MetricsItem> items = Sets.newHashSet(
            MetricsItem.SUPERVISOR_STATS,
            MetricsItem.TOPOLOGY_STATS,
            MetricsItem.THROUGHPUT,
            MetricsItem.SPOUT_THROUGHPUT,
            MetricsItem.SPOUT_LATENCY
            );
    return new BasicMetricsCollector(config, topology, items);
  }

}