преобразование строки / json в pyspark df query - PullRequest
0 голосов
/ 20 января 2020

У меня есть строка / json, которая является запросом DQ, я хочу преобразовать ее в соответствующий запрос pyspark df, используя python

sample string/json:
{Test({c_equal(col1) = '1'} and({c_isNull(col2)}) and {c_equal(col3)='TEST'}) RESULT 'pass' OTHERWISE 'fail'

Expected sample output:
df.withcolumn(Test,df.when(col==1) and col2.isNull .......

Я пытался использовать pyparsing, но не смог этого добиться.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...