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歲的名字=“鮑勃”)))