Spark 操作Hive 实现滑动窗口

可以使用 Spark SQL 中的窗口函数来实现滑动窗口，具体操作可以参考以下代码：

import org.apache.spark.sql.functions._
import org.apache.spark.sql.expressions.Window

val windowSpec = Window.partitionBy("key").orderBy("timestamp").rangeBetween(-10, 0)

val result = spark.sql("SELECT key, value, timestamp FROM table_name")
  .withColumn("rolling_sum", sum("value").over(windowSpec))

其中，`key` 是分组的字段，`timestamp` 是时间戳字段，`value` 是需要计算的值。`rangeBetween(-10, 0)` 表示计算当前行及前面 10 行的和，即滑动窗口大小为 11。