Реализация вложенного if else в карте pyspark - PullRequest
Новая
       41

Реализация вложенного if else в карте pyspark

0 голосов
/ 08 октября 2019

Я должен использовать функцию поиска, чтобы извлечь значения из информационного кадра, используя условие из 3 других информационных кадров. Я реализовал вложенный if else в pyspark map, но я получаю синтаксические ошибки в операторах if. Я понятия не имею, что не так. 

aroDF=tempDF.rdd.map(lambda r: if lookupDF.lookup(r["CoreExtractId"] ):

if policyGrpCheckDF.lookup(r["GROUPNUMBER"]):


if PGOffShoreAllowedDF.lookup(r["GROUPNUMBER"]):


IsRestricted=1)

Я хочу, чтобы программа tempDF сначала проверила условие в dataframe lookupDF, затем переместилась в dataFrame policyGrpCheckDF, затем переместилась в PGOffShoreAllowedDF dataframe, и все условия удовлетворяют, а статут будетзапустить. CoreExtractId и GROUPNUMBER являются именами столбцов. Любая помощь будет оценена.

ошибка: 

 aroDF=tempDF.rdd.map(lambda r:  if lookupDF.lookup(r["CoreExtractId"] ):

                                 ^
SyntaxError: invalid syntax
...