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

))  
  •                           {  
  •                               if(valueToCheck < Double.parseDouble(thresholdValue.toString()))  
  •                               {  
  •                                    count.incrementAndGet();  
  •                                    if(count.get() > frequency)  
  •                                        splitAndEmit(inputTupleList,collector);  
  •                               }  
  •                           }  
  •                           else if(frequencyChkOp.equals(">"))