在pyspark中将月份名称转换为数字

cuxqih21  于 2021-05-29  发布在  Spark
关注(0)|答案(1)|浏览(470)
  1. +--------+-----+---+----+----+----+----+-----+-----------+-----------+
  2. |Currency|Month|Day|Year|Open|High| Low|Close| Volume| Market Cap|
  3. +--------+-----+---+----+----+----+----+-----+-----------+-----------+
  4. | tezos| Dec| 04|2019|1.29|1.32|1.25| 1.25| 46,048,752|824,588,509|
  5. | tezos| Dec| 03|2019|1.24|1.32|1.21| 1.29| 41,462,224|853,213,342|
  6. | tezos| Dec| 02|2019|1.25|1.26|1.20| 1.24| 27,574,097|817,872,179|
  7. | tezos| Dec| 01|2019|1.33|1.34|1.25| 1.25| 24,127,567|828,296,390|
  8. | tezos| Nov| 30|2019|1.31|1.37|1.31| 1.33| 28,706,667|879,181,680|
  9. | tezos| Nov| 29|2019|1.28|1.34|1.28| 1.31| 32,270,224|867,085,098|
  10. | tezos| Nov| 28|2019|1.26|1.35|1.22| 1.28| 44,240,281|845,073,679|
  11. | tezos| Nov| 27|2019|1.24|1.27|1.16| 1.26| 47,723,271|829,672,736|
  12. | tezos| Nov| 15|2019|1.22|1.26|1.15| 1.17| 32,203,363|773,992,543|
  13. +--------+-----+---+----+----+----+----+-----+-----------+-----------+

这是我的Pypark数据报,我怎么能把月名转换成数字???谢谢您

q7solyqu

q7solyqu1#

使用 from_unixtime and unix_timestamp 功能。 Example: ```
df.show()

+-----+

|Month|

+-----+

| Dec|

| Nov|

+-----+

df.withColumn("mnth_name",from_unixtime(unix_timestamp(col("Month"),'MMM'),'MM')).show()

+-----+---------+

|Month|mnth_name|

+-----+---------+

| Dec| 12|

| Nov| 11|

+-----+---------+

展开查看全部

相关问题