【发布时间】: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