風暴拓撲與服務器中的HBase之間的連接

Question

我將HBase存儲在服務器中的docker上。我創建了一個風暴拓撲包含HBaseBolt和我連接HBaseBolt如下代碼：

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

我如何通過HBase的服務器的連接參數拓撲？

Answer 1

請看下面的例子：

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

在拓撲配置可以設置HBase的配置屬性。