Convertire una semplice stringa di una riga di RDD in Spark

Question

Ho una linea semplice:

line = "Hello, world" 

Vorrei convertirlo in un RDD con un solo elemento. Ho provato

sc.parallelize(line) 

Ma ottenere:

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

Tutte le idee?

Answer 1

provare a utilizzare List come parametro:.

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

esso restituisce

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