Flink中map、filter和flatMap算子有何区别与联系？

本文共计209个文字，预计阅读时间需要1分钟。

`map()` 函数基本是一对一服务，即输入一个元素，输出一个元素；`flatMap()` 相对于 `map()`，实现 MapFunction 也仅支持一对一的转换。有时你需要处理一个输入元素，但需要输出一个或多个元素。

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

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

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