Динамическая передача фильтра из файла json в фрейме данных pySpark - PullRequest
0 голосов
/ 08 января 2020

Я пытаюсь передать выражение фильтра из файла json. В выражении есть несколько встроенных функций pyspark для фильтрации.

Json выглядит так: но он не работает, вместо этого выдает ошибку, что фильтр ожидает столбец или строку.

 df1 = df.filter(expr(var))
...