"Python中spark-查找每行的长度"

Question

我写了这个代码：

logFile = sc.textFile("\README.md") #read the file

def lengthfunction(line):
    return len(line) 

logFile.map(lambda line: line.split()).reduce(lengthfunction)

它给了我一个错误：

^{pr2}$

我也试过了

logFile.map(lambda line: line.split()).reduce(lambda line: len)

但这也没用。 有人能帮我吗？在

Answer 1

您可以：

logFile.map(lambda line: line.split()).map(len)