Я делаю программу подсчета слов в PySpark, но каждый раз, когда я go запускаю ее, я получаю следующую ошибку:
NameError: global name 'lower' is not defined
Эти две строки и создают мне проблему:
wordsCount = words.map(lambda word: (word,lower(), 1)) \
.reduceByKey(lambda numOfWord1, numOfWord2: numOfWord1 + numOfWord2) \
.map(lambda word: (word[0],word[1], word[1]/float(total_words)))
charsCount = chars.map(lambda char: (char.lower(), 1)) \
.reduceByKey(lambda numOfchar1, numOfchar2: numOfchar1 + numOfchar2)
Может кто-нибудь сказать мне, что я здесь делаю не так?
Спасибо!