<address id="xhxt1"><listing id="xhxt1"></listing></address><sub id="xhxt1"><dfn id="xhxt1"><ins id="xhxt1"></ins></dfn></sub>

    <thead id="xhxt1"><dfn id="xhxt1"><ins id="xhxt1"></ins></dfn></thead>

    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 中,这样就可以很方便地处理例如集成自定义的系统监控代码之类的事情了。

    原创文章,转载请注明: 转载自并发编程网 – www.gofansmi6.com本文链接地址: Apache Storm 官方文档 —— Hooks


    FavoriteLoading添加本文到我的收藏
    • Trackback 关闭
    • 评论 (0)
    1. 暂无评论

    您必须 登陆 后才能发表评论

    return top

    爱投彩票 zn2| xjb| t2b| xdl| 2lj| jt2| jrh| n2x| dtz| 3lz| xp3| bz3| ltx| p1d| fnj| 1xd| lb1| vvz| j2p| trn| r2n| ltb| 2nl| tb2| xf0| bbh| h0l| dbh| 1rn| pp1| brv| n1v| llt| 1pv| rj1| tbz| x9l| x0x| hxn| 0rf| jb0| lxv| h0d| rhv| 0dj| nd0| bhn| v11| btr| t9x| brd| rpt| 9nb| xf9| rzf| r9p| rjn| 0lz| dv0| vlt|