扒皮狼

关注

flink算子之map、filter和flatMap

扒皮狼

关注

阅读 64

2022-07-18


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

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

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


相关推荐

悲催博士僧

Flink DataStream 算子 Map、FlatMap、Filter、KeyBy、Reduce、Fold、Aggregate

悲催博士僧 39 0 0

星河出山

Flink转换算子——flatMap/map/filter/keyby/reduce综合练习

星河出山 17 0 0

有点d伤

flink从入门到精通系列之:map、flatmap、filter

有点d伤 62 0 0

骑在牛背上看书

【flink番外篇】1、flink的23种常用算子介绍及详细示例(1)- map、flatmap和filter

骑在牛背上看书 37 0 0

松鼠树屋

Flink常用API之转换算子->Map、reduce、Filter、KeyBy、Aggregations

松鼠树屋 70 0 0

fbd4ffd0717b

Spark算子:RDD基本转换操作map、flatMap

fbd4ffd0717b 73 0 0

圣杰

map 和 flatMap 区别

圣杰 90 0 0

闲云困兽

map()和flatMap()的区别

闲云困兽 87 0 0

whiteMu

【Flink1.14实战】Flink DataStream 算子快速开始 Filter

whiteMu 63 0 0

小编

map和flatMap的区别

小编 56 0 0

精彩评论(0)

0 0 举报