mysql日期格式与sparksql日期格式

ykejflvf 于 2021-06-20 发布在 Mysql

关注(0)|答案(1)|浏览(435)

我有sql语句，我需要在sparksql中运行，但是我不能在spark中正确地格式化它
mysql数据库

select DATE_FORMAT(NOW(),'%Y-%m-01')

sparksql语言

spark.sql("""
  SELECT date_format(current_date(),'yyyy-MM-01')"""
).show()

所以我想达到的是，把任何日期都转换成一个月的第一天

1条答案

最后我用了这个，但我认为舒尔thre是更好的解决方案，如果您有，请随意分享

spark.sql("""
  SELECT date_add( last_day( add_months(CAST(current_timestamp() as DATE), -1 ) ),1)
  """
).show()