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

 if(field.getColumnType().equalsIgnoreCase("int"))  
  •                    prepStatement.setInt(dbIndex,  
  •                        Integer.parseInt(inputTupleList.get(i).toString()));  
  •                else if(field.getColumnType().equalsIgnoreCase("long"))  
  •                    prepStatement.setLong(dbIndex,   
  •                        Long.parseLong(inputTupleList.get(i).toString()));  
  •                else if(field.getColumnType().equalsIgnoreCase("float"))  
  •                    prepStatement.setFloat(dbIndex,   
  •                        Float.parseFloat(inputTupleList.get(i).toString()));  
  •