我正在使用[codahale metrics]获取storm的螺栓和喷嘴的度量,并发送到graphite服务器。我怎样才能有时间在螺栓和喷嘴之间发送消息?例如。此代码仅用于每个执行者的度量:
import com.codahale.metrics.Histogram;
import com.codahale.metrics.Meter;
import com.codahale.metrics.Timer;
public class MqttSensorDetailSpout extends BaseRichSpout {
private Meter tupleMeter;
private Timer tupleTimer;
private Histogram tupleHistogram;
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
this.context = context;
this.collector = collector;
this.tupleMeter = context.registerMeter("meterSpout-" + this.topic);
this.tupleTimer = context.registerTimer("timerSpout-" + this.topic);
this.tupleHistogram = context.registerHistogram("histogramSpout-" + this.topic);
}
public void nextTuple() {
final Timer.Context timeContext = this.tupleTimer.time();
this.tupleMeter.mark();
try {
…
} finally {
timeContext.stop();
}
}
}
我想知道在执行者之间发送消息所用的时间。我将如何实施它?谢谢,菲利佩
1条答案
按热度按时间mccptt671#
storm不会给消息加时间戳,因为我们无法确定人们是否在他们的服务器上设置了ntp或类似的东西。如果您想知道将元组从一个执行器发送到另一个执行器需要多长时间,那么应该手动向发送的元组添加时间戳。您可以像添加任何其他元组字段一样添加它。然后,您的下游bolt可以读取输入元组的时间戳,并计算传输所需的时间。