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

}

createQuery.append("thresholdTimeStamp timestamp)");

connection.prepareStatement(createQuery.toString()).execute();

// Insert Query

StringBuilder insertQuery = new StringBuilder("INSERT INTO "+tableName+"(");

String tempCreateQuery = new String();

for(Field fields : tupleInfo.getFieldList())

{

insertQuery.append(fields.getColumnName()+",");

}