前言
在上一篇我们演示了如何使用Flink 的Table Api 读取文件数据，并过滤特定字段的数据，本篇在上一篇的基础上，将从CSV文件中读取的数据重新输出到一个新的CSV文件中；
在实际业务场景下，也有不少类似的操作，即源文件放在某个文件目录下，通过flink程序读取，然后按照业务规则对读取进来的数据做适当的转换等类似ETL的操作，之后再输出到其他的地方，可以是文件系统，或者数据库、kafka、es等；
本例演示将数据写出到一个新的CSV文件中；
前置准备
准备一个CSV格式的文件，内容如下：
核心代码如下：
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.DataTypes;
import org.apache.flink.table.api.Table;
import org.apache.flink版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由半码博客整理，本文链接：https://www.bmabk.com/index.php/post/143298.html
