使用Storm实现实时大数据分析!

  • 经由Bolt发送的的tuple将会传递到下一个对应的Bolt,在我们的用例中是DBWriterBolt。

    DBWriterBolt

    经过处理的tuple必须被持久化以便于触发tigger或者更深层次的使用。DBWiterBolt做了这个持久化的工作并把tuple存入了数据库。表的建立由prepare()函数完成,这也将是topology调用的第一个方法。方法的编码如Listing Six所示。

    Listing Six:建表编码。

    1. public void prepare( Map StormConf, TopologyContext context )   
    2. {         
    3.     try