sparksql 求当前周的周一

Spark SQL 中，你可以使用 `from_unixtime` 函数和一些日期算术来获取当前周的周一。首先，你需要将当前时间转换为Unix时间戳（秒级别），然后加减相应的偏移量来得到周一的时间戳。以下是一个示例：

import org.apache.spark.sql.functions._
import org.apache.spark.sql.types._

val currentTimestamp = spark.sql("current_timestamp").cast("timestamp") // 获取当前时间

// 计算从当前时间到本周一的偏移量
val daysToMonday = Calendar.SATURDAY - Calendar.MONDAY + 1 // 周日是一周的第一天，所以需要加一天
val mondayTimestamp = currentTimestamp.unix_timestamp() + (daysToMonday * 86400) // Unix时间戳乘以一天的秒数（86400）

// 将Unix时间戳转换回日期格式
val currentDate = from_unixtime(mondayTimestamp, "yyyy-MM-dd")

currentDate.show()

这将显示当前周的开始日期。注意，这个例子假设你的Spark环境已经配置好并连接到了数据库。