eine einfache Linie Zeichenfolge RDD in Spark-

Question

Ich habe eine einfache Linie:

line = "Hello, world" 

Ich mag würde es zu einer RDD konvertieren mit nur einem Element. Ich habe

versucht

sc.parallelize(line) 

Aber es bekommen:

sc.parallelize(line).collect() 
['H', 'e', 'l', 'l', 'o', ',', ' ', 'w', 'o', 'r', 'l', 'd'] 

Irgendwelche Ideen?

Answer 1

versuchen Liste als Parameter verwendet wird.

sc.parallelize(List(line)).collect() 

es

res1: Array[String] = Array(hello,world)