pyspark.sql.functions.struct

pyspark.sql.functions。 结构体 ( *关口:联盟[ColumnOrName、列表(ColumnOrName_)元组[ColumnOrName_,…]] )→pyspark.sql.column.Column

创建一个新的结构列。

参数

关口 列表,集,str或列

列名或列包含在输出结构。

例子

> > >df。选择(结构体(“年龄”,“名字”)。别名(“结构”))。收集()(行(struct =行(= 2岁的名字=“爱丽丝”))、行(struct =行(= 5岁的名字=“鲍勃”)))> > >df。选择(结构体([df。年龄,df。的名字])。别名(“结构”))。收集()(行(struct =行(= 2岁的名字=“爱丽丝”))、行(struct =行(= 5岁的名字=“鲍勃”)))

以前的

pyspark.sql.functions.spark_partition_id

下一个

pyspark.sql.functions.when