pyspark to_timestamp()返回空值

to_timestamp(col, format=None)

from pyspark.sql import SparkSession
from pyspark.sql.functions import to_timestamp

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

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

# 将字符串转换为时间戳
df = df.withColumn("timestamp", to_timestamp(df.timestamp_str))

# 显示结果
df.show()

+-------------------+-------------------+
|     timestamp_str|          timestamp|
+-------------------+-------------------+
|2022-01-01 12:00:00|2022-01-01 12:00:00|
|2022-02-01 00:00:00|2022-02-01 00:00:00|
|       invalid_date|               null|
+-------------------+-------------------+