Spark SQL 的核心是Catalyst优化器,首先将SQL处理成未优化过的逻辑计划(Unresolved Logical Plan),其只包括数据结构,不包含任何数据信息。...Flink SQL 是Fllink提供的SQL的SDK API。SQL是比Table更高阶的API,集成在Table library中提供,在流和批上都可以用此API开发业务。
?...();
ds.collectAsList().forEach(it->System.out.println(it));
}
}
spark的程序非常简单,就可以实现对csv进行查询...接下来直接通过SQL进行查询就好了。...25,0,10,2,0,44,29)
(10,热尔维尼奥,帕尔马,21,0,9,0,0,21,15)
(11,伊卡尔迪,国际米兰,23,0,9,3,2,44,23)
好了,两个案例还是非常简单的,都只是进行了数据的简单查询