Python Pyspark：使用 F.current_date() 过滤当前日期前 1 天
Python Pyspark: Filter for 1 Day Before Current Date Using F.current_date()
我想为特定日期之前的所有日期过滤我的数据集。特别是当前日期前 1 天。
我试过下面的代码：
df = df.filter(F.col('date') <= F.current_date() - 1)
但我收到以下错误：
u"cannot resolve '(current_date() - 1)' due to data type mismatch: differing types in '(current_date() - 1)' (date and int)
F.date_sub 方法应该有效：
df.filter(F.col('date') <= F.date_sub(F.current_date(), 1))
我想为特定日期之前的所有日期过滤我的数据集。特别是当前日期前 1 天。
我试过下面的代码：
df = df.filter(F.col('date') <= F.current_date() - 1)
但我收到以下错误：
u"cannot resolve '(current_date() - 1)' due to data type mismatch: differing types in '(current_date() - 1)' (date and int)
F.date_sub 方法应该有效：
df.filter(F.col('date') <= F.date_sub(F.current_date(), 1))