将 GraphX 数据保存到 Spark 的块管理器

如何解决将 GraphX 数据保存到 Spark 的块管理器

我是 Apache GraphX 库和 Spark 框架的新手。我正在使用 GraphX 进行一个项目。我有以下格式的示例数据

val users: RDD[(VertexId,(String,String))] =
      lc.parallelize(Seq((3L,("XXX","Student")),(7L,("YYY","Postdoc")),(5L,("ZZZ","Prof")),(2L,"Prof"))))


val relationships: RDD[Edge[String]] = {
  lc.parallelize(Seq(Edge(3L,7L,"Collab"),Edge(5L,3L,"Advisor"),Edge(2L,5L,"Colleague"),"PI")))

val graph= Graph（用户，关系）

我想把图形数据转换成数据库表的形式存入Spark的

具有以下表结构的内部BlockManager

relationship_table(srcId: Long,desId:Long,property: Array[T])

Users_table(VertexId:Long,details:Array[T]).

我想编写一个名为 save_data(graph:Graph(Users,relationships) 的函数，该函数将数据以表格的形式保存在 Spark 的 BlockManager 中。

因此，我想查询数据并将其用于后续的 graphx 转换。主要目的是永久保存数据并随时调用。

熟悉 Spark 的 BlockManager 和 GraphX 的人可以指导我如何解决问题吗？

我期待收到您的来信。

在此先感谢您。

最好的问候，