python - Spark で単純な 1 行の文字列を RDD に変換する

Question

私は簡単な行を持っています:

line = "Hello, world"

要素が1つだけのRDDに変換したいと思います。私が試してみました

sc.parallelize(line)

しかし、次のようになります。

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

何か案は？

Answer 1

リストをパラメータとして使用してみてください：

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

それは返す

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