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

  •         Integer timeWindow = thresholdInfo.getTimeWindow();  
  •          int frequency = thresholdInfo.getFrequencyOfOccurence();  
  •          if(thresholdDataType.equalsIgnoreCase("string"))  
  •          {  
  •              String valueToCheck = inputTupleList.get(thresholdColNum-1).toString();  
  •              String frequencyChkOp = thresholdInfo.getAction();  
  •              if(timeWindow!=null)  
  •              {  
  •                  long curTime = System.currentTimeMillis();  
  •                  long diffInMinutes = (curTime-startTime)/(1000