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

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