Преобразование SQL в Dataframe - PullRequest
0 голосов
/ 10 мая 2018

Мне нужна помощь в том, как преобразовать этот код SAS в Pyspark DataFrame?Я пытался вычислить даты (+/- 2)

Pysaprk Новые вычисления дат -

nuclear_df = nuclear_df.withColumn("two_before",F.lit(date_sub(nuclear_df.withColumn(FDOS_LN),2)))
                               .withColumn("two_after",F.lit(date_add(FDOS_LN,2))

SAS-код, который необходимо преобразовать в pyspark DF:

select * from radio_df where MBR_ID not in 
      ( select distinct MBR_ID from radio_df a , nuclear_df b 
         where a.MBRID =b.MBR_ID and a.FDOS_LN between two_before and two_after )
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...