APISonar


com.alibaba.jstorm.common.metric.AsmMetric.MetricOp.LOG

> com > alibaba > jstorm > common > metric > AsmMetric > MetricOp > LOG
com APIs alibaba APIs jstorm APIs common APIs metric APIs AsmMetric APIs MetricOp APIs LOG APIs

Example 1
public void prepare(Map stormConf, TopologyContext context)
    {
        super.prepare(stormConf, context);
        metricClient = new MetricClient(context);
        successCounter = metricClient.registerCounter(InOrderTestMetricsDef.METRIC_BOLT_SUCCESS);
        successCounter.setOp(AsmMetric.MetricOp.LOG & AsmMetric.MetricOp.REPORT);
        failCounter = metricClient.registerCounter(InOrderTestMetricsDef.METRIC_BOLT_FAIL);
        failCounter.setOp(AsmMetric.MetricOp.LOG & AsmMetric.MetricOp.REPORT);
    }
Example 2
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
        this.collector = collector;
        this.task = context.getThisTaskIndex();
        this.metricClient = new MetricClient(context);
        this.emitCounter = metricClient.registerCounter(InOrderTestMetricsDef.METRIC_SPOUT_EMIT);
        this.emitCounter.setOp(AsmMetric.MetricOp.LOG & AsmMetric.MetricOp.REPORT);
        LOG.info("open. task = " + task);
    }