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

;Object>) tuple.getValues();  
  •        int dbIndex=0;  
  •        for(int i=0;i<tupleInfo.getFieldList().size();i++)  
  •        {  
  •            Field field = tupleInfo.getFieldList().get(i);  
  •            try {  
  •                dbIndex = i+1;  
  •                if(field.getColumnType().equalsIgnoreCase("String"))               
  •                    prepStatement.setString(dbIndex, inputTupleList.get(i).toString());  
  •                else