这不是
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|# +--------------+----------+
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)