欢迎光临散文网 会员登陆 & 注册

Flink中,如何将DataStream中的一个元素转换为n个元素

2023-06-08 14:00 作者:ingemar-  | 我要投稿

将DataStream中的每一个元素转换为0...n个元素


示例

读取flatmap.log文件中的数据 

如:


张三,苹果手机,联想电脑,华为平板

李四,华为手机,苹果电脑,小米平板


转换为


张三有苹果手机

张三有联想电脑

张三有华为平板

李四有…


思路


以上数据为一条转换为三条,显然,应当使用flatMap来实现分别在flatMap函数中构建三个数据,并放入到一个列表中



步骤


  • 构建批流理运行环境

  • 构建本地集合数据源

  • 使用flatMap将一条数据经过处理转换为三条数据

  • 使用逗号分隔字段

  • 分别构建三条数据

  • 打印输出



参考代码



Flink中,如何将DataStream中的一个元素转换为n个元素的评论 (共 条)

分享到微博请遵守国家法律