flatMap引发错误unicode项没有属性flatMap

Question

给定输入rdd或窗体

1: 6 7
2: 5

我怎样才能得到另一个rdd表格

^{pr2}$

等等。。在

失败，消息为unicode项没有属性flatMap

def get_str(x,y):
    ..code to flatmap 
    return op
text = sc.textFile(inputs)
res = text.map(lambda l:l.split(":")).map(lambda (x,y):get_str(x,y))

Answer 1

我不是很喜欢Python，但是看起来你想在你的flatMap里面使用flatMap，但是你需要用flatMap替换你的map。在Scala中，我会：

val text = sc.textFile(inputs)
val res = text.map(l => l.split("[\\s:]+"))
              .flatMap(list => list.drop(1).map(i => (list(0), i)))

请注意，我在" "和":"上拆分以获得值列表。在

在Python中也是一样：

^{pr2}$