Мне нужна помощь в том, как преобразовать этот код 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 )