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