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

(timeWindow!=null)  
  •                 {  
  •                      long valueToCheck =                          Long.parseLong(inputTupleList.get(thresholdColNum-1).toString());  
  •                      long curTime = System.currentTimeMillis();  
  •                      long diffInMinutes = (curTime-startTime)/(1000);  
  •                      System.out.println("Difference in minutes="+diffInMinutes);  
  •                      if(diffInMinutes>=timeWindow)  
  •                      {  
  •                           if(frequencyChkOp.equals("<"