Spark RDD API扩展开发(2):自定义RDD � 过往记忆
在本博客的《Spark RDD API扩展开发(1)》文章中我介绍了如何在现有的RDD中添加自定义的函数。本文将介绍如何自定义一个RDD类,假如我们想对没见商品进行打折,我们想用Action操作来实现这个操作,下面我将定义IteblogDiscountRDD类来计算商品的打折,步骤如下:
Read full article from Spark RDD API扩展开发(2):自定义RDD � 过往记忆
Spark RDD API扩展开发(2):自定义RDD � 过往记忆
在本博客的《Spark RDD API扩展开发(1)》文章中我介绍了如何在现有的RDD中添加自定义的函数。本文将介绍如何自定义一个RDD类,假如我们想对没见商品进行打折,我们想用Action操作来实现这个操作,下面我将定义IteblogDiscountRDD类来计算商品的打折,步骤如下:
Read full article from Spark RDD API扩展开发(2):自定义RDD � 过往记忆
No comments:
Post a Comment