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

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