多易 Flink内核原理与源码解析
查询表
//table apival sensorTable = tableEnv.from("inputTable")val resultTable = sensorTable.select('id, 'temperature).filter('id === "sensor_1")// SQLval resultSqlTable = tableEnv.sqlQuery("""
|select id, temperature
|from inputTable
|where id = 'sensor_1'
""".stripMargin)
