Flink SQL 是Fllink提供的SQL的SDK API。SQL是比Table更高阶的API,集成在Table library中提供,在流和批上都可以用此API开发业务。
?...,25,0,10,2,0,44,29
10,热尔维尼奥,帕尔马,21,0,9,0,0,21,15
11,伊卡尔迪,国际米兰,23,0,9,3,2,44,23
数据列代表,排名、球员、所属俱乐部、比赛、红牌...,25,0,10,2,0,44,29]
[10,热尔维尼奥,帕尔马,21,0,9,0,0,21,15]
[11,伊卡尔迪,国际米兰,23,0,9,3,2,44,23]
Flink SQL
import...org.apache.flink.api.java.tuple.Tuple10;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.java.BatchTableEnvironment...,25,0,10,2,0,44,29)
(10,热尔维尼奥,帕尔马,21,0,9,0,0,21,15)
(11,伊卡尔迪,国际米兰,23,0,9,3,2,44,23)
好了,两个案例还是非常简单的,都只是进行了数据的简单查询