使用Spark Scala将月份减去日期

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

// 创建SparkSession
val spark = SparkSession.builder()
  .appName("Subtract Month from Date")
  .getOrCreate()

// 导入隐式转换
import spark.implicits._

// 创建示例数据集
val data = Seq(("2022-05-15"), ("2023-10-20"), ("2024-02-10"))
val df = data.toDF("date")

// 将字符串类型的日期转换为日期类型
val dateDF = df.select(to_date($"date").as("date"))

// 使用Spark函数进行月份减去日期的计算
val resultDF = dateDF.select(date_sub($"date", dayofmonth($"date")).as("result"))

// 显示结果
resultDF.show()