前言
在上一篇我们通过代码演示，通过读取kafak的数据，然后将数据再次写出到kafka中，本篇将分享使用Flink Table Api 如何将读取到的文件的数据写出到mysql ;
业务应用
在某些场景下，通过读取源数据后，需要经过flink程序的处理，然后将数据持久化存储到数据库、或es等，作为后续其他业务继续使用
代码演示
前置准备，在resource目录下，准备一个测试用的csv文件，作为flink读取的数据的源文件，内容如下：
本例，我们将沿用上一篇的案例逻辑，通过读取csv文件，再通过Flink Table Api 的使用将读取到的数据进行聚合统计，最后将统计结果写出到mysql中，因此需要提前创建一张表；
如下是提前创建好的空表，这里有2个字段，一个是id，一个是统计结果值；
版权声明：本文为congge_study原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接和本声明。