flatMap算子和map有些相似,输入都是数据流中的每个元素,与之不同的是,flatMap的输出可以是零个、一个或多个元素,当输出元素是一个列表时,flatMap会将列表展平。
flatMap
map
如下图所示,输入是包含圆形或正方形的列表,flatMap过滤掉圆形,正方形列表被展平,以单个元素的形式输出。
输入多个列表进行 过滤、...等一系列逻辑处理。然后输出扁平化的列表结果。
← flink的应用场景有哪些?注意要说明数据源流程逻辑。 Flink零基础学习教程map算子原理 →