我有一个要转换为pyspark的sql查询:
select * from Table_output where cct_id not in (select * from df_hr_excl)
伪代码:
Table_output=Table_output.select(col("cct_id")).exceptAll(df_hr_excl.select("cct_id")) or
col("cct_id").isin(df_hr_excl.select("cct_id"))
我有一个要转换为pyspark的sql查询:
select * from Table_output where cct_id not in (select * from df_hr_excl)
伪代码:
Table_output=Table_output.select(col("cct_id")).exceptAll(df_hr_excl.select("cct_id")) or
col("cct_id").isin(df_hr_excl.select("cct_id"))
1条答案
按热度按时间dw1jzc5e1#
where子句中与
NOT IN
或者NOT EXISTS
可以使用左反联接写入:根据您的注解,如果您的子查询中有一个条件,那么您可以将其放入join条件中。例如。: