val dataStream = inputStream
.map(data => {
val arr = data.split(",")
SensorReading(arr(0), arr(1).toLong, arr(2).toDouble)
})
//创建表
val dataTable = tableEnv.fromDataStream(dataStream)
//表里直接获取数据
val resultTable = dataTable
.select("id,temperature")
.filter("id == 'sensor_1'")
//注册表，写sql
tableEnv.createTemporaryView("sensor_table",dataTable)
val sql = "select id,temperature from sensor_table where id = 'sensor_1'"
val resultSqlTable = tableEnv.sqlQuery(sql)
