У меня есть строка / 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, но не смог этого добиться.