Flink是不能直接用 sql api, 要用stream api map 取出来再用sql api 做进步的处理吗？![Flink是不能直接用 sql api？-[阿里云_云淘科技]](http://www.cnzhanzhang.com/wp-content/uploads/2024/01/20240111120853-659fda5519b9f.png)
![Flink是不能直接用 sql api？-[阿里云_云淘科技]](https://www.cnzhanzhang.com/wp-content/themes/justnews/themer/assets/images/lazy.png)
以下为热心网友提供的参考意见
Apache Flink确实支持SQL API。它提供了两种顶层的关系型API，即Table API和SQL。Flink通过Table API和SQL实现了批流统一处理。Table API是用于Scala和Java的集成查询API，允许以直观的方式组合关系运算符（例如select，where和join）的查询。Flink SQL基于Apache Calcite实现了标准SQL，用户可以使用标准的SQL处理数据集。
Flink的Table & SQL API可以处理用SQL语言编写的查询语句，但这些查询需要嵌入用Java或Scala编写的表程序中，而这些程序在提交到集群前需要使用构建工具进行打包。此外，Flink提供了一个SQL客户端，目的是提供一种简单的方式来编写、调试和提交表程序到Flink集群上，而无需写一行Java或Scala代码。
Flink对SQL的支持基于实现了SQL标准的Apache Calcite。你可以通过SQL客户端或环境配置文件来定义和操作source表，连续查询，sink表，以及寻找表。同时，Flink也支持通过SQL查询和Table API查询两种方式混合使用来查询Table。
以下为热心网友提供的参考意见
你直接用的话数据太乱了，你自己map成{“id”:””,””:”” ….,”createtime”:””}这种数据看的不更清楚吗 ，此回答整理自钉群“【③群】Apache Flink China社区”
本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：https://www.cnzhanzhang.com/22090.html