2016-10-17 37 views
0

我想分割使用的文本文件。作爲分隔符。被「」分割。在Spark中使用flatMap作爲文本文件

val rdd2=rdd1.flatMap(x=>x.split(".")) 

但它不工作。我也嘗試過使用反斜槓()。如。在Linux中是一個狂野的角色。但它仍然不分裂。

+0

試試這個VAL RDD2 = rdd1.flatMap(X => x.split( 「\\」)) –

+0

請了投票,如果你接受的答案 –

回答

0

你必須給出如下。

val rdd2=rdd1.flatMap(x=>x.split("\\."))