流批一体数据转换

数据转换算子官网网址

基本转换算子

• map算子：主要用于将数据流中的数据进行转换，形成新的数据流。简单来说，就是一个“一一映射”，消费一个元素就产出一个元素。

  

  

• flatMap算子：又称为扁平映射，主要是将数据流中的整体（一般是集合类型）拆分成一个一个的个体使用。消费一个元素，可以产生 0 到多个元素。

  

  

• filter算子：将按照条件对输入数据集进行筛选操作，将符合条件的数据集输出，将不符合条件的数据过滤掉。

  

实时效果反馈

1. 以下选项中关于Flink数据转化算子描述正确的是？

A map算子：主要用于将数据流中的数据进行转换，形成新的数据流。简单来说，就是一 个“一一映射”，消费一个元素就产出一个元素。

B flatMap算子：又称为扁平映射，主要是将数据流中的整体（一般是集合类型）拆分成 一个一个的个体使用。消费一个元素，可以产生 0 到多个元素。

C filter算子：将按照条件对输入数据集进行筛选操作，将符合条件的数据集输出，将不符 合条件的数据过滤掉。

D 以上三个选项都正确。

答案：

1=>D