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

        prepStatement.setTimestamp(dbIndex+1new java.sql.Timestamp(now.getTime()));  
  •         prepStatement.addBatch();  
  •         counter.incrementAndGet();  
  •         if (counter.get()== batchSize)   
  •         executeBatch();  
  •     }   
  •     catch (SQLException e1)   
  •     {  
  •         e1.printStackTrace();  
  •     }             
  •    }  
  •    else 
  •    {  
  •