似乎您错过了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()
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)