如何根据我在pyspark中的前一个行值将分钟添加到给定的时间戳

from pyspark.sql import SparkSession
from pyspark.sql.window import Window
from pyspark.sql.functions import lag, col, expr
from pyspark.sql.types import IntegerType

spark = SparkSession.builder.appName("AddMinutesToTimestamp").getOrCreate()

data = [(1, "2022-01-01 10:00:00"), (2, "2022-01-01 10:01:00"), (3, "2022-01-01 10:02:00")]
df = spark.createDataFrame(data, ["id", "timestamp"])

windowSpec = Window.orderBy("id")
df = df.withColumn("prev_timestamp", lag(col("timestamp")).over(windowSpec))

df = df.withColumn("new_timestamp", expr("date_add(prev_timestamp, interval 1 minute)"))

df.show()