You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Spark Scala窗口函数中如何添加IGNORE NULLS参数?

在Scala Spark中为lead函数添加IGNORE NULLS的实现方式

在Scala版本的Spark API中,要实现SQL里lead(rn, 1) IGNORE NULLS的效果,直接在lead函数后链式调用.ignoreNulls方法即可,修正后的代码如下:

val my_df = my_table
  .withColumn("next_rn", lead($"rn", 1).ignoreNulls.over(Window.orderBy("rn")))

这个.ignoreNulls方法和SQL中的IGNORE NULLS语义完全一致,会在计算lead偏移值时忽略null数据。

内容的提问来源于stack exchange,提问作者M.S.Visser

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.06.15 00:00:55