は、どのように私は次のように、文字列のリストのRDDを持っているのScala

Question

で、リスト内の要素の組み合わせを作成します次のように入力します。

(('a','b'),('a','c'),('b','c'),('1','2'),('1','3'),('1','4'),('2','3'),'('2','4'),('3','4'),('e','f'),...) 

どのようにするのですか？

Answer 1

あなたはList.combinationsでflatMapを使用することができます。

val rdd = sc.parallelize(Seq(List("a", "b", "c"), List("1", "2", "3", "4"), List("e", "f"))) 
// rdd: org.apache.spark.rdd.RDD[List[String]] = ParallelCollectionRDD[0] at parallelize at <console>:24 

rdd.flatMap(list => list.combinations(2)).collect() 
// res1: Array[List[String]] = Array(List(a, b), List(a, c), List(b, c), List(1, 2), List(1, 3), List(1, 4), List(2, 3), List(2, 4), List(3, 4), List(e, f))