public static void collectMetrics()

in src/main/java/com/aliyun/emr/example/storm/benchmark/util/Helper.java [63:78]

• 14 lines of code
• 2 McCabe index (conditional complexity)

    public static void collectMetrics(String topologyName, Integer pollInterval) throws Exception {
        Map clusterConf = Utils.readStormConfig();
        Nimbus.Client client = NimbusClient.getConfiguredClient(clusterConf).getClient();
        BasicMetricsCollector metricsCollector = new BasicMetricsCollector(client, topologyName, clusterConf);

        try {
            while (true){
                metricsCollector.collect(client);
                Thread.sleep(pollInterval * 1000);
            }
        } finally {
            metricsCollector.close();
            kill(client, topologyName);
        }

    }