【发布时间】:2023-02-07 14:26:50
【问题描述】:
如何使用 Pyspark 将长“1206946690”转换为日期格式“yyyy-mm-dd”。
【问题讨论】:
如何使用 Pyspark 将长“1206946690”转换为日期格式“yyyy-mm-dd”。
【问题讨论】:
使用 spark.sql.functions 模块的 from_unixtime 函数和 cast 方法在 PySpark 中将 Long 类型转换为日期格式。 像这样的东西;
从 pyspark.sql.functions 导入 from_unixtime,转换
timestamp_df = spark.createDataFrame([(1206946690,)], ['long_column']) timestamp_df = timestamp_df.withColumn("timestamp_column", from_unixtime(timestamp_df["long_column"]))
date_df = timestamp_df.withColumn("date_column", cast("timestamp_column", "date"))
date_df.show()
【讨论】: