PySpark 只得到分钟？答案

【问题标题】：PySpark get minute only?PySpark 只得到分钟？
【发布时间】：2022-01-12 03:55:52
【问题描述】：

在雪花中，您可以执行以下操作：

SELECT
my_event_time,
DATE_TRUNC('minute',my_event_time)::TIME AS minute
FROM table

它会返回类似：

my_event_time             | minute
-------------------------------------
2020-08-17 13:23:49.227.  | 13:23:00

删除除实际分钟之外的所有内容，这可以在 Pyspark df 中完成吗？ Pyspark 中的 date_trunc('minute', ...) 做了其他事情，它不会删除日期部分。

【问题讨论】：

【解决方案1】：

使用date_format函数并传递所需的时间格式。

spark.sql("select date_format(current_timestamp,'HH:mm:ss') time").show()

+--------+
|    time|
+--------+
|10:48:13|
+--------+

【讨论】：

【解决方案2】：

试试这个

spark.sql("current_timestamp,minute(current_timestamp)").show()

【讨论】：