赞
踩
简介
Spark GraphX中提供了方便开发者的基于谷歌Pregel API
的迭代算法,因此可以用Pregel
的计算框架来处理Spark上的图数据。GraphX的Pregel API
提供了一个简明的函数式算法设计,用它可以在图中方便的迭代计算,如最短路径、关键路径、n度关系等,也可以通过对一些内部数据集的缓存和释放缓存操作来提升性能。
编程要求
根据图1运用pregel
函数找出距离Ann最远的顶点。补全代码中的内容,使得程序运行结果如预期输出。具体请参见后续测试样例。
测试说明
平台会对你编写的代码进行测试:
测试输入:
预期输出:
- import org.apache.log4j.{Level, Logger}
- import org.apache.spark.{SparkConf, SparkContext}
- import org.apache.spark.graphx._
-
- object farthest_distance{
- def main(args: Array[String]): Unit = {
- val conf = new SparkConf().setAppName("farthest distance").setMaster("local[4]
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。