pyspark.sql.functions.struct¶
-
pyspark.sql.functions。
結構體
( *關口:聯盟[ColumnOrName、列表(ColumnOrName_)元組[ColumnOrName_,…]] )→pyspark.sql.column.Column¶ -
創建一個新的結構列。
例子
> > >df。選擇(結構體(“年齡”,“名字”)。別名(“結構”))。收集()(行(struct =行(= 2歲的名字=“愛麗絲”))、行(struct =行(= 5歲的名字=“鮑勃”)))> > >df。選擇(結構體([df。年齡,df。的名字])。別名(“結構”))。收集()(行(struct =行(= 2歲的名字=“愛麗絲”))、行(struct =行(= 5歲的名字=“鮑勃”)))