如何将文本文件数据转换为邻接表

Question

我有以下图形文本文件，这是一个大文件，我想在 Scala 中转换为邻接表。下面给出的文本文件的前几行：

src, dst,dist  
A,C,5.0
A,B,8.0
B,C,6.0
B,D,7.0
B,A,8.0
C,A,5.0
C,B,6.0
D,B,7.0
D,E,8.0
E,D,8.0

我想把它转换成如下格式的邻接列表。

"A"->List((8.0,"B"),(5.0,"C"))

请指导我在 Scala 中将其转换为邻接表的好方法。

Answer 1

由于没有跟进：

 val zs = """A,C,5.0
A,B,8.0
B,C,6.0
B,D,7.0
B,A,8.0
C,A,5.0
C,B,6.0
D,B,7.0
D,E,8.0
E,D,8.0"""

将字符串解析为 Seq of Seq...

val as = zs.split('\n').toSeq.map(_.split(',').toSeq)

做成key,value。 Value 是一个单元素 Seq，因为它使 reduceByKey 易于使用

val bs = as.map{case Seq(k,v,d) => (k, Seq((v,d)))}.reduceByKey(_ ++ _)
// Map(E -> List((D,8.0)),
//     A -> List((C,5.0), (B,8.0)),
//     B -> List((C,6.0), (D,7.0), (A ,8.0)),
//     C -> List((A,5.0), (B,6.0)),
//     D -> List((B,7.0), (E,8.0)))

其中一个（稍微简单的）reduceByKey是

implicit class SparkOps[K, V]( xs:Traversable[(K,V)]) {
   def reduceByKey(f:(V,V)=>V)= 
       xs.groupBy(_._1).mapValues{x=>x.unzip._2.reduce(f)}

   }

("simplistic" 因为它总是 returns 一个 Map 而不是与输入相同的 Traversable。

如何将文本文件数据转换为邻接表

How to convert Text file data into Adjucency list

scala

adjacency-list

adjacency-matrix