【发布时间】:2019-03-29 22:39:17
【问题描述】:
我在转换带有日期的列时遇到了一些问题。我的日期列看起来像这样“20032016”“ddMMyyyy”。当我转换它时,我只得到空值。 我使用了以下代码:
df.withColumn("reporting_date",date_format(to_date(col("reporting_date"), "ddMMyyyy"), "yyyy-MM-dd")).show
有人可以帮助我吗?
【问题讨论】:
我在转换带有日期的列时遇到了一些问题。我的日期列看起来像这样“20032016”“ddMMyyyy”。当我转换它时,我只得到空值。 我使用了以下代码:
df.withColumn("reporting_date",date_format(to_date(col("reporting_date"), "ddMMyyyy"), "yyyy-MM-dd")).show
有人可以帮助我吗?
【问题讨论】:
您的代码示例对我有用:
scala> val df = Seq("20032016").toDF
df: org.apache.spark.sql.DataFrame = [value: string]
scala> df.withColumn("reporting_date",date_format(to_date(col("value"), "ddMMyyyy"), "yyyy-MM-dd")).show
+--------+--------------+
| value|reporting_date|
+--------+--------------+
|20032016| 2016-03-20|
+--------+--------------+
【讨论】: