Flink中,如何将DataStream中的一个元素转换为n个元素
将DataStream中的每一个元素转换为0...n个元素
示例
读取flatmap.log文件中的数据
如:
张三,苹果手机,联想电脑,华为平板
李四,华为手机,苹果电脑,小米平板
转换为
张三有苹果手机
张三有联想电脑
张三有华为平板
李四有…
…
…
思路
以上数据为一条转换为三条,显然,应当使用flatMap来实现分别在flatMap函数中构建三个数据,并放入到一个列表中
步骤
构建批流理运行环境
构建本地集合数据源
使用flatMap将一条数据经过处理转换为三条数据
使用逗号分隔字段
分别构建三条数据
打印输出
参考代码
