如何在PySpark中打印current_date()的执行结果？

你之前的尝试都只返回Column对象，是因为PySpark的函数（比如fn.current_date()）本质是列表达式定义，不是直接计算出的具体值——PySpark采用懒执行机制，只有触发实际的计算动作（action）时，才会执行表达式并返回真实结果。

以下是几种能看到current_date()实际值的方法：

方法1：通过DataFrame显示或取值 #

from pyspark.sql import functions as fn

# 创建包含当前日期的DataFrame（Databricks中SparkSession已默认初始化）
df = spark.createDataFrame([(1,)], ["dummy_col"]).withColumn("current_date", fn.current_date())

# 用Databricks的display工具查看表格形式的结果
display(df)

# 直接提取具体日期值
date_result = df.select("current_date").collect()[0][0]
print(date_result)

方法2：直接执行SQL查询 #

# 执行SQL查询并获取结果
date_result = spark.sql("SELECT current_date()").first()[0]
print(date_result)

方法3：创建单行空DataFrame #

如果不需要额外列，可以直接生成只含当前日期的DataFrame：

df = spark.sql("SELECT current_date() as today")
display(df)

只要触发collect()、first()、display()这类action操作，PySpark就会实际计算current_date()的结果，返回具体的日期对象（比如Python的datetime.date类型）。

内容的提问来源于stack exchange，提问作者SCool