Apache Spark转换 - 分割线并创建它的组合

Question

我有一个Spark RDD，如下所示。

abc,def,ghi 

sdfdf,sdfsdf,dfdf444sdsdd 

我想通过用逗号（，）分割每个记录（行）来创建2个分散值的所有不同组合。

输出RDD（例如）低于

abc def 

abc ghi 

def ghi 

Answer 1

flatMap必须用于组合部分。使用类似以下内容：

rdd.map(_.split(",")).flatMap(tokens => getCombinations(tokens)) 

...其中getCombinations有签名：

def getCombinations(tokens: List[String]): List[(String, String)]