簡單介紹

可以在JStorm的控制檯看見。

和常見的java metrics系統一樣，支援

• Counter:累計值
• Gauge：瞬時值
• Histogram：瞬時值的分佈

使用

public class MyBolt extends BaseBasicBolt {

    private MetricClient metricClient;
    private AsmCounter myCounter;

    @Override
    public void prepare(Map stormConf, TopologyContext context)
 
 {
        metricClient = new MetricClient(context);
        myCounter = metricClient.registerCounter("myCounter");
    }

    public void execute(Tuple input, BasicOutputCollector collector) {
        Object value = input.getValueByField("value");
        myCounter.inc();
        if(value instanceof
 
 UmetripEvent){
            System.out.println("RECEIVE");
            UmetripEvent event = (UmetripEvent)value;

        }
       //throw new FailedException("manual fail");


    }

    public void declareOutputFields(OutputFieldsDeclarer declarer) {
        declarer.declare(new Fields("EVENT"));
    }
 



}