apache sparkで交差しない交差点

Question

私はapache spark intersectionメソッドを使用して2つのRDD Stringの交差点を見つけようとしていますが、空の配列を返します。

val d=sc.parallelize(Seq("web services as a software","RCB vs CSK")) 

val d1 = sc.parallelize(Seq("software as a services", "CSK vs RCB")) 

d.intersection(d1).collect 

出力

RES6：配列[文字列] =配列（）

Answer 1

あなたが単語に文章を分割一部欠けている：

val d=sc.parallelize(Seq("web services as a software","RCB vs CSK")).flatMap(_.split(" ")) 

val d1 = sc.parallelize(Seq("software as a services", "CSK vs RCB")).flatMap(_.split(" ")) 

d.intersection(d1).collect