问题描述
我是 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 的人可以指导我如何解决问题吗?
我期待收到您的来信。
在此先感谢您。
最好的问候,
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)