Flink SQL 是Fllink提供的SQL的SDK API。SQL是比Table更高阶的API,集成在Table library中提供,在流和批上都可以用此API开发业务。
?...使用calcite cost-based optimizor 进行优化。...).forEach(it->System.out.println(it));
}
}
spark的程序非常简单,就可以实现对csv进行查询,
option("header", "true")
设置了第一行作为列头...]
[4,米利克,那不勒斯,26,0,14,0,1,61,34]
[5,皮亚特克,热那亚,19,0,13,2,0,56,31]
[6,因莫比莱,拉齐奥,24,0,12,3,3,65,35]
[7,卡普托...POJO,使用了元组,但是这样其实不是个好习惯,无形中增加了编程的复杂度。