GraphX中如何从RDD[(Long,Long,String)]构造RDD[Edge[String]]？

你遇到的核心问题是没有将三元组包装成Edge实例，而是直接返回了(Long, Long, String)类型的元组，这和目标类型RDD[Edge[String]]不匹配。另外代码里的expRelation变量看起来没有明确的来源，我也会帮你一起梳理清楚。

错误点拆解 #

你的代码最后一步返回的是普通三元组：

(src.toLong, dst.toLong, expRelation)

但GraphX的Edge必须通过它的构造方法Edge(srcId: VertexId, dstId: VertexId, attr: ED)来创建，直接返回元组会导致类型完全不兼容，这就是你遇到问题的关键原因。

修正后的代码 #

假设你想把expRelation作为Edge的属性值（比如它是业务中的边关系描述），同时确保join后的结构逻辑正确，修正后的代码应该是这样的：

val c: RDD[(String, String)] = something
val s: RDD[(String, String)] = something
// 请确保expRelation有合理的来源：比如是固定业务值，或是从join的结果中提取的字段
val edgeRDD: RDD[Edge[String]] = c.join(s).map { 
  case (num: String, (src: String, dst: String)) => 
    // 用Edge构造方法包装数据，VertexId本质就是Long类型，所以src.toLong和dst.toLong是正确的
    Edge(src.toLong, dst.toLong, expRelation) 
}

额外注意事项 #

• 如果expRelation不是固定值，而是需要从join的结果中获取，比如你的c或s的第二个元素本身就是关系描述，那需要调整解构逻辑。比如如果c是RDD[(String, (String, String))]（键是num，值是(src, relation)），s是RDD[(String, String)]（键是num，值是dst），那join后应该写成case (num, ((src, expRelation), dst))，这样就能正确拿到expRelation。
• 要确保src和dst的字符串可以正常转换为Long，否则会抛出NumberFormatException，可以考虑提前校验数据格式，或者在转换时加上异常捕获逻辑。

内容的提问来源于stack exchange，提问作者Litchy