小编Ran*_*ana的帖子

我正在尝试使用Apache Spark从管道("|")分隔文件生成格式化的CSV文件.输入文件包含:

苹果|球|猫

布莱克顿| Bela vista | 格里纳克

X | Y | Z

我正在尝试:

val name= sc.textFile(input.txt")
val split=name.map(line=>line.split("|")).map( x => (x(0),x(2)) )
split.foreach(println)

输出:

(X,Y)

(A,P)

(B,A)

我要求的输出是:

(苹果,猫)

(布莱克敦,格林纳克)

(X,Z)