我可以更改Spark数据框中的列的可空性吗？

我可以更改Spark数据框中的列的可空性吗？

似乎您错过了StructType（newSchema）。

l = [('Alice', 1)]df = sqlContext.createDataframe(l, ['name', 'age'])df = df.withColumn('foo', F.when(df['name'].isNull(),False).otherwise(True))df.schema.fieldsnewSchema = [StructField('name',StringType(),True), StructField('age',LongType(),True),StructField('foo',BooleanType(),False)]df2 = sqlContext.createDataframe(df.rdd, StructType(newSchema))df2.show()