首页 > 解决方案 > pyspark 爆炸函数

问题描述

from pyspark.sql.functions import explode_outer
df1 = df.withColumn("col1",explode_outer(col1)).show()

我的样本数据

col1
usa,uk,mexico
india,japan

如何通过pyspark爆炸功能实现预期的列

预期成绩

usa
uk
mexico
india
japan

标签: pysparkapache-spark-sqlexplode

解决方案


推荐阅读