2017-02-10 1 views
0

J'ai HBase stocké à docker dans un serveur. J'ai créé une topologie Storm qui contient HBaseBolt et je connecté HBaseBolt comme ci-dessous le code:Connexion entre Storm Topology et HBase dans un serveur

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

Comment puis-je passer les paramètres de connexion du serveur HBase à Topologie?

Répondre