在雪花中,您可以執行以下操作:
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 中完成嗎?將date_trunc('minute', ...)在Pyspark做別的東西,它不洗掉的日期部分。
uj5u.com熱心網友回復:
使用date_format函式并傳遞所需的時間格式。
spark.sql("select date_format(current_timestamp,'HH:mm:ss') time").show()
--------
| time|
--------
|10:48:13|
--------
uj5u.com熱心網友回復:
試試這個
spark.sql("current_timestamp,minute(current_timestamp)").show()
轉載請註明出處,本文鏈接:https://www.uj5u.com/gongcheng/378896.html
標籤:阿帕奇火花 约会时间 火花 apache-spark-sql
上一篇:pyspark結構化流kafka-py4j.protocol.Py4JJavaError:呼叫o41.save時發生錯誤
下一篇:ActionController::UnknownFormat(ActionController::UnknownFormat):銷毀時
