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

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