小编Jac*_*ack的帖子

IndentationError:databricks 和 pyspark 中出现意外缩进

from pyspark.sql.functions import *


ghj=finalDF.withColumn("temp", explode(split(regexp_replace(to_json(struct(col("sum(P0)"), col("sum(P1)"), col("sum(P2)"), col("sum(P3)"), col("sum(P4)"), col("sum(P5)"))),"""[\{"\}]""",""), ",")))
           .withColumn("Priority", split(col("temp"),":")[0])
           .withColumn("Count", split(col("temp"),":")[1]).select(col("NAME"), col("SHORT_DESCRIPTION"), col("Priority"), col("Count")).show()
Run Code Online (Sandbox Code Playgroud)

python apache-spark-sql

0
推荐指数
2
解决办法
5472
查看次数

标签 统计

apache-spark-sql ×1

python ×1