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

       }  
  •    }  
  • }  
  •    
  • public void executeBatch() throws SQLException  
  • {  
  •     batchExecuted=true;  
  •     prepStatement.executeBatch();  
  •     counter = new AtomicInteger(0);  
  • 一旦Spout和Bolt准备就绪(等待被执行),topology生成器将会建立topology并准备执行。下面就来看一下执行步骤。

    在本地集群上运行和测试topology