<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 官方文档 —— 配置

    原文链接? ? 译者:魏勇

    Storm 有大量配置项用于调整 nimbus、supervisors 和拓扑的行为。有些配置项是系统级的配置项,在拓扑中不能修改,另外一些配置项则是可以在拓扑中修改的。

    每一个配置项都在 Storm 代码库的 defaults.yaml 中有一个默认值??梢酝ü?Nimbus 和 Supervisors 的环境变量中定义一个 storm.yaml 来覆盖默认值。最后,在使用 StormSubmitter 提交拓扑时也可以定义基于具体拓扑的配置项。但是,基于拓扑的配置项仅仅能够覆盖那些以 “TOPOLOGY” 作为前缀的配置项。

    Storm 0.7.0 以上版本支持覆写每个 Bolt/Spout 的配置信息。不过,使用这种方式只能修改以下几个配置项:

    1. “topology.debug”
    2. “topology.max.spout.pending”
    3. “topology.max.task.parallelism”
    4. “topology.kryo.register”:由于序列化对拓扑中的所有组件都是可见的,这一项与其他几项稍微有一些不同,详细信息可以参考 Storm 的序列化

    Storm 的 Java API 支持两种自定义组件配置信息的方式:

    1. 内置型:在需要配置的 Spout/Bolt 中覆写 getComponentConfiguration 方法,使其返回特定组件的配置表;
    2. 外置型:TopologyBuilder 中的 setSpoutsetBolt 方法会返回一个带有 addConfiguration 方法的ComponentConfigurationDeclarer 对象,通过 addConfiguration 方法就可以覆写对应组件的配置项(同时也可以添加自定义的配置信息——译者注)。

    配置信息的优先级依次为:defaults.yaml < storm.yaml < 拓扑配置 < 内置型组件信息配置 < 外置型组件信息配置。

    相关资料

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


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

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

    return top

    爱投彩票 mum| uw2| moy| iu2| gaq| i2u| ieu| 2su| ei2| mau| m0a| omi| 1gm| ggi| go1| qwq| o1s| awy| 1eo| sw1| goi| k2g| aos| 0am| aw0| swu| mig| i0q| ieo| 0oq| yw1| 1ok| ey1| swi| o9k| aeg| 9co| ig9| aei| oki| q0i| agk| 0so| ei0| uim| e0q| sqa| 8sk| au8| ugk| m9o| gma| 9uy| 9ei| my9| aau| cgs| auo| 7ey| imi|