У меня есть следующий скрипт для панд, но я хочу применить ту же логику к scala, используя spark.
# add a column containing previous timestamp
toy_data = pd.concat([toy_data,
toy_data.groupby('user_id').transform(lambda x:x.shift(1))]
,axis=1)
Как я смогу воссоздать сценарий в Scala?