首页 > 解决方案 > 将空列添加到具有空值(按类型)的数据框 pyspark

问题描述

我有以下列表:

columns = [('url','string'),('count','bigint'),('isindex','boolean')]

我想用空值将此列添加到我的 df 中:

for column in columns:
df = df.withColumn(column[0], f.lit(?).cast(?))

我不确定我需要在 lit 函数和演员表中添加什么以便为每种类型提供合适的空值

谢谢!

标签: pysparkapache-spark-sql

解决方案


推荐阅读