温馨提示  2024年 6月我们已经停止开发者板块文章内容更新,谢谢来访。存档数据
知识 2023-08-27 27 次阅读

spark api编程中如何在spark 1.2版本实现对union、groupbyke的分析

   

本篇文章给大家分享的是有关spark api编程中如何在spark 1.2版本实现对union、groupbyke的分析,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完本文后可以有所收获,话不多说,跟着小编一起来看看吧。

下面看下union的使用

使用collect操作查看一下执行结果

再看下groupbykey的使用

join操作就是一个笛卡尔积操作的过程,如下示例

使用collect查看执行结果

可以看出join操作完全就是一个笛卡尔积的操作;

reduce本身在rdd操作中属于一个action类型的操作,会导致job的提交和执行

下面我们看下lookup的使用

以上就是spark api编程中如何在spark 1.2版本实现对union、groupbyke的分析,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过本文学到更多知识。更多详情敬请关注云行业资讯频道。