Я пробовал агрегатную функцию, которая преподавалась в видео лекции. Я столкнулся с ошибкой при ее выполнении.
sumCount = flightsParsed.map(lambda x:x.DEP_DELAY).aggregate((0,0),(lambda acc,value:(acc[0]+value,acc[1]+1)),(lambda acc1,acc2:(acc1[0]+acc2[0],acc1[1]+acc2[1])))
Ошибка:
TypeError: неподдерживаемые типы операндов для +: 'float' и 'NoneType'
PS: я пробовал упражнения на Databricks, загружая CSV как DF с инфершемой, установленной в `True ', а затем преобразовал его в RDD для дальнейшей обработки.
Из того, что я понял из сообщения об ошибке, нет значения, которое передается лямбда-выражению. Есть ли какой-нибудь способ, которым я мог видеть вывод только лямбда-функций для отладки там, где происходит точная проблема?