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

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