Не может создать столбец max, с пониманием списка. сумма столбцов работ

Question

Я пытаюсь создать столбец max с этим кодом. Столбец суммы работ

сумма

for col in list_names:
    for month in [3,6,9,12]:
        companies = companies.withColumn(col + 'sum_'+ str(month) + '_months', sum(companies[col + ult_pats2[month_ix - ix]] for ix in range(month)) )

макс:

for col in list_names:
    for month in [3,6,9,12]:
        companies = companies.withColumn(col + 'max_'+ str(month) + '_months', max(companies[col + ult_pats2[month_ix - ix]] for ix in range(month)) )

сообщение об ошибке:

"ValueError: Невозможно преобразовать столбец в bool: пожалуйста, используйте '&' для 'и', '|' для 'or', '~' для 'not' при построении логического значения DataFrame Выражения "

Answer 1

Это похоже на переписывание функции max другим пакетом. Попробуйте:

import pyspark.sql.functions as f

А затем используйте ссылку f.max(...)