我需要Year, Month, Day, Hour從 Spark df 中的列中獲取字符串Time。我還需要將這些值保存在單獨的列中。數據如下：ID Time111 2020-03-23-12:40:04112 2020-04-23-12:40:04113 2020-05-23-12:40:04期望的輸出是：ID Year Month Day111 2020 03 23112 2020 04 23113 2020 05 23我試過：data_df.select( year("Time").alias('year'), month("Time").alias('month'), dayofmonth("Time").alias('day')).show()它返回所有 Null 值。
1 回答
UYOU
TA貢獻1878條經驗 獲得超4個贊
我假設該Time列是一個字符串。您可以使用正則表達式提取所需的值，但這會非常痛苦。另一種選擇是將字符串轉換為時間戳，然后使用函數等year。month
另外，您的時間戳不是標準格式，因此您需要指定它。
data = [(111, '2020-03-23-12:40:04'),
(112, '2020-04-23-12:40:04'),
(113, '2020-05-23-12:40:04')]
df = spark.createDataFrame(data, ['ID', 'Time'])
df\
.withColumn('t', F.to_timestamp('Time', 'yyyy-MM-dd-HH:mm:ss'))\
.select('ID',
F.year('t').alias('year'),
F.month('t').alias('month'),
F.dayofmonth('t').alias('day'),
F.hour('t').alias('hour')
).show()
產生：
+---+----+-----+---+----+
| ID|year|month|day|hour|
+---+----+-----+---+----+
|111|2020| 3| 23| 12|
|112|2020| 4| 23| 12|
|113|2020| 5| 23| 12|
+---+----+-----+---+----+
添加回答
舉報
0/150
提交
取消