当前位置:   article > 正文

educoder-Spark GraphX—寻找社交媒体中的“影响力用户”

spark graphx—寻找社交媒体中的“影响力用户”

第1关:认识Pregel API

简介

        Spark GraphX中提供了方便开发者的基于谷歌Pregel API迭代算法,因此可以用Pregel的计算框架来处理Spark上的图数据。GraphX的Pregel API提供了一个简明的函数式算法设计,用它可以在图中方便的迭代计算,如最短路径、关键路径、n度关系等,也可以通过对一些内部数据集的缓存和释放缓存操作来提升性能。

编程要求

        根据图1运用pregel函数找出距离Ann最远的顶点。补全代码中的内容,使得程序运行结果如预期输出。具体请参见后续测试样例。

测试说明

        平台会对你编写的代码进行测试:

        测试输入:
        预期输出:

 

  1. import org.apache.log4j.{Level, Logger}
  2. import org.apache.spark.{SparkConf, SparkContext}
  3. import org.apache.spark.graphx._
  4. object farthest_distance{
  5. def main(args: Array[String]): Unit = {
  6. val conf = new SparkConf().setAppName("farthest distance").setMaster("local[4]
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/你好赵伟/article/detail/666738
推荐阅读
相关标签
  

闽ICP备14008679号