这不是
pyspark特定的。您可以使用
add_months。从 Spark 1.5开始 可用。例如:
spark.sql("select current_date(), add_months(current_date(),1)").show()# +--------------+-----------------------------+# |current_date()|add_months(current_date(), 1)|# +--------------+-----------------------------+# | 2016-12-27| 2017-01-27|# +--------------+-----------------------------+您还可以使用负整数删除月份:
spark.sql("select current_date(), add_months(current_date(),-1) as last_month").show()# +--------------+----------+# |current_date()|last_month|# +--------------+----------+# | 2016-12-27|2016-11-27|# +--------------+----------+


