閱讀354 返回首頁    go 阿裏雲 go 技術社區[雲棲]


Apache Storm 官方文檔 —— Hooks

Storm 提供了一種 hooks 機製,可以實現在 Storm 的各種事件流中運行自定義代碼的功能。可以通過繼承 BaseTaskHook類來創建 hook,還可以根據需要在繼承的子類中覆寫適當的方法來跟蹤相關事件。

注冊 hook 有兩種方法:

  1. 在 spout 的 open 方法或者 bolt 的 prepare 方法中使用 TopologyContext#addTaskHook 方法;
  2. 使用 Storm 配置表中的 topology.auto.task.hooks 配置項。之後這些 hook 會自動注冊到每個 spout 和 bolt 中,這樣就可以很方便地處理例如集成自定義的係統監控代碼之類的事情了。

最後更新:2017-05-22 13:32:19

  上一篇:go  Apache Storm 官方文檔 —— 分布式 RPC
  下一篇:go  Apache Storm 官方文檔 —— Metrics