当前位置 : 主页 > 编程语言 > java >

flink算子之map、filter和flatMap

来源:互联网 收集:自由互联 发布时间:2022-07-20
map() map()基本是一对一服务,即输入一个元素输出一个元素; flatMap() 对于map()来说,实现MapFunction也只是支持一对一的转换。 那么有时候你需要处理一个输入元素,但是要输出一个或者


map()
map()基本是一对一服务,即输入一个元素输出一个元素;

flatMap()
对于map()来说,实现MapFunction也只是支持一对一的转换。
那么有时候你需要处理一个输入元素,但是要输出一个或者多个输出元素的时候,就可以用到flatMap()。

Filter
DataStream->DataStream
根据条件进行判断,用于满足条件的数据进行输出,不满足就过滤掉。


上一篇:金融市场知识3.1--股票
下一篇:没有了
网友评论