我正在使用 spark 2.1.0。我无法在我使用以下代码片段的 pyspark 中创建时间戳列。请帮忙
df=df.withColumn('Age',lit(datetime.now()))
我得到了
assertion error:col should be Column
请帮忙
最佳答案
我不确定 2.1.0,至少在 2.2.1 上你可以:
from pyspark.sql import functions as F
df.withColumn('Age', F.current_timestamp())
希望对您有所帮助!
关于python - Pyspark 创建时间戳列,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45469438/