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

Flink流计算常用算子之Union使用方法及代码演示

2023-06-16 15:24 作者:ingemar-  | 我要投稿

将多个DataSet合并成一个DataSet

【注意】union合并的DataSet的类型必须是一致的

图片


示例


将以下数据进行取并集操作

数据集1

数据集2


步骤

构建批处理运行环境

使用 fromCollection 创建两个数据源

使用 union 将两个数据源关联在一起

打印测试

注意:union可以取并集,但是不会去重。


参考代码


Flink流计算常用算子之Union使用方法及代码演示的评论 (共 条)

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