首页
Python
Java
前端
数据库
Linux
Chatgpt专题
开发者工具箱
colname专题
用spark获取前一行数据,DF.withColumn(colName,lag(colName,offset).over(Window.partitionBy().orderBy(desc())))
数据: 1,11,1112,22,2223,33,3331,22,3331,22,444 代码: package com.emg.etp.analysis.preproces.nullphotoimport com.emg.etp.analysis.preproces.nullphoto.pojo.EcarDataimport org.apache.spark.{SparkConf
阅读更多...