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

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