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

3);  
  •               LocalCluster cluster = new LocalCluster();  
  •               cluster.submitTopology(  
  •               "Threshold_Test", conf, builder.createTopology());  
  •           }  
  •      }  
  • topology被建立后将被提交到本地集群。一旦topology被提交,除非被取缔或者集群关闭,它将一直保持运行不需要做任何的修改。这也是Storm的另一大特色之一。

    这个简单的例子体现了当你掌握了topology、spout和bolt的概念,将可以轻松的使用Storm进行实时处理。如果你既想处理大数据又不想遍历Hadoop的话,不难发现使用Storm将是个很好的选择。

    原文链接:Easy, Real-Time Big Data Analysis Using Storm (编译/仲浩 王旭东/审校)