小编fro*_*ark的帖子

无法将 LongType 转换为 DateType 错误

(PySpark 新手)

我做了很多搜索并尝试了很多不同的方式,我在这里发布我的最后一次尝试:我的数据框看起来像:

txn_dt datetime64[ns] id int64

我正在尝试使用 Spark SQL 将 txn_dt 连接到另一个日期类型并获取错误类型不匹配,因此我尝试使用以下代码将 txn_dt 转换为日期:

df = df.withColumn("txn_dt_tmp",df["txn_dt"].cast(DateType())) \
                                        .drop("txn_dt") \
                                        .withColumnRenamed("txn_dt_tmp", "txn_dt")
Run Code Online (Sandbox Code Playgroud)

但得到

org.apache.spark.sql.AnalysisException: cannot resolve 'CAST(`txn_dt` AS DATE)' due to data type mismatch: cannot cast LongType to DateType;
Run Code Online (Sandbox Code Playgroud)

请帮忙

type-conversion pyspark

6
推荐指数
1
解决办法
1万
查看次数

标签 统计

pyspark ×1

type-conversion ×1