前言
在上一篇我们通过代码演示，通过读取kafak的数据，然后将数据再次写出到kafka中，本篇将分享使用Flink Table Api 如何将读取到的文件的数据写出到mysql ;
业务应用
在某些场景下，通过读取源数据后，需要经过flink程序的处理，然后将数据持久化存储到数据库、或es等，作为后续其他业务继续使用
代码演示
前置准备，在resource目录下，准备一个测试用的csv文件，作为flink读取的数据的源文件，内容如下：
本例，我们将沿用上一篇的案例逻辑，通过读取csv文件，再通过Flink Table Api 的使用将读取到的数据进行聚合统计，最后将统计结果写出到mysql中，因此需要提前创建一张表；
如下是提前创建好的空表，这里有2个字段，一个是id，一个是统计结果值；
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/143296.html
