在Spark中将简单的单行字符串转换为RDD [英] Convert a simple one line string to RDD in Spark

问题描述

我有一条简单的话:

line = "Hello, world"

我想将其转换为仅包含一个元素的RDD. 我尝试过

I would like to convert it to an RDD with only one element. I have tried

sc.parallelize(line)

但是它得到了

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

有什么想法吗?

推荐答案

尝试使用列表作为参数:

try using List as parameter:

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

它返回

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

这篇关于在Spark中将简单的单行字符串转换为RDD的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！