使用Storm实现实时大数据分析！_大数据_计算头条_中国计算网——工业互联网一站式服务平台—

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

connection.prepareStatement("DROP TABLE IF EXISTS "+tableName).execute();

StringBuilder createQuery = new StringBuilder(

"CREATE TABLE IF NOT EXISTS "+tableName+"(");

for(Field fields : tupleInfo.getFieldList())

{

if(fields.getColumnType().equalsIgnoreCase("String"))

createQuery.append(fields.getColumnName()+" VARCHAR(500),");

else

createQuery.append(fields.getColumnName()+" "+fields.getColumnType()+",");