Spark Graphx计算指定节点的N度关系节点源码

直接上代码：

其中sortResult方法里对Traversable[(K,V)]类型的集合使用了reduceByKey方法，这个方法是自行封装的，使用时需要导入，代码如下：

 

总结

以上就是本文关于SparkGraphx计算指定节点的N度关系节点源码的全部内容了，希望对大家有所帮助。感兴趣的朋友可以参阅：   等，有什么问题请留言，小编会及时回复大家的。

原文链接：http://www.cnblogs.com/yepei/p/6323545.html