关于Spark GraphX,如何在顶点使用其他数据类型



在此处输入图像描述

如您所见,"3L,5L,7L,2L"是一种长数据类型。

如何使用其他 Scala 数据类型,例如字符串。

我遇到了类似的问题,我仍然不知道这是否可能。不过,我可以分享一些解决方法。就我而言,我为所有顶点分配了 ID。希望会有所帮助

val VertexRDD: RDD[(VertexId, Array[String])] = vfile.map(line => line.split(",")).zipWithIndex().map(_.swap)

最新更新