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

  • 通过TopologyBuilder建立topology。
  • 使用Storm Submitter,将topology递交给集群。以topology的名字、配置和topology的对象作为参数。
  • 提交topology。
  • Listing Eight:建立和执行topology。

    1. public class StormMain  
    2. {  
    3.      public static void main(String[] args) throws AlreadyAliveException,   
    4.                                                    InvalidTopologyException,   
    5.                                                    InterruptedException