多易 Flink內(nèi)核原理與源碼解析
查詢表
//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)
標簽：
