将1小时添加到Pyspark数据框中的时间戳列

from pyspark.sql import SparkSession
from pyspark.sql.functions import col, expr, date_add

# 创建SparkSession
spark = SparkSession.builder.getOrCreate()

# 创建示例数据框
data = [("2022-01-01 12:00:00",)]
df = spark.createDataFrame(data, ["timestamp"])

# 将字符串类型的时间戳列转换为Timestamp类型
df = df.withColumn("timestamp", col("timestamp").cast("timestamp"))

# 添加1小时到时间戳列
df = df.withColumn("new_timestamp", date_add(col("timestamp"), 1))

# 显示结果
df.show(truncate=False)