【问题标题】:Connection between Storm Topology and HBase in a server服务器中 Storm 拓扑和 HBase 之间的连接
【发布时间】:2017-02-10 06:55:11
【问题描述】:

我将 HBase 存储在服务器中的 docker 中。我创建了一个包含 HBaseBolt 的 Storm 拓扑,并按以下代码连接了 HBaseBolt:

    TopologyBuilder builder = new TopologyBuilder();
    ...
    builder.setBolt("indexer", new HBaseBolt("webpage", mapper)).localOrShuffleGrouping("parse").withConfigKey(CONFIG_KEY);
    ...    
    return submit("crawl", conf, builder);

如何将 HBase 服务器的连接参数传递给 Topology?

【问题讨论】:

    标签: hbase apache-storm


    【解决方案1】:

    看这个例子:

    http://www.programcreek.com/java-api-examples/index.php?api=org.apache.storm.hbase.bolt.HBaseBolt

    在拓扑配置中,您可以设置 hbase 配置属性。

    【讨论】:

    • 我看过这些例子,但是我不知道如何传递存储hbase及其配置文件的服务器的ip和端口。
    猜你喜欢
    • 2016-08-11
    • 1970-01-01
    • 2013-03-19
    • 2015-08-03
    • 2019-05-24
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多