前言
在JDK8之后，经常可以见到lamda表达式的写法，通过各种lamda表达式可以简化代码的编写，让代码看起来更加简洁，比如大家熟知的 filter ， map 等方法，前者可以对集合中的数据进行过滤，后者可以很方便的对对象数据进行字段的规整转换等操作
在flink中，也提供了类似的API操作，方便的对输入流数据进行处理，俗称：转换算子，下面对flink中常用的几个转换算子进行举例说明
1、Map操作
比如以读取下面的外部文件为例，在该文本文件中存在下面的内容
很明显，通过程序读取的时候，会一行行对数据进行解析，通过flink提供的map方法，可以将每一行读取的数据传入到map方法体中，然后可以根据实际情况，对当前行的数据做进一步处理
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.da版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之音整理，本文链接：https://www.bmabk.com/index.php/post/143327.html
