天天看點

Apache Storm 官方文檔 —— Metrics

storm 提供了一個可以擷取整個拓撲中所有的統計資訊的度量接口。storm 内部通過該接口可以跟蹤各類統計數字:executor 和 acker 的數量、每個 bolt 的平均處理時延、worker 使用的最大堆容量等等,這些資訊都可以在 nimbus 的 ui 界面中看到。

使用 metrics 隻需要實作一個接口方法:<code>getvalueandreset</code>,在方法中可以查找彙總值、并将該值複位為初始值。例如,在 meanreducer 中就實作了通過運作總數除以對應的運作計數的方式來求取均值,然後将兩個值都重新設定為 0。

storm 提供了以下幾種 metric 類型:

<a href="https://github.com/apache/storm/blob/master/storm-core/src/jvm/backtype/storm/metric/api/reducedmetric.java">reducedmetric</a>