pyspark.sql.functions.arrays_zip

pyspark.sql.functions。 arrays_zip ( *關口:ColumnOrName )→pyspark.sql.column.Column

收藏功能:返回一個合並的結構體數組的第n個結構體包含所有n值的輸入數組。

參數

關口 列或str

列的數組合並。

例子

> > >從pyspark.sql.functions進口arrays_zip> > >df=火花。createDataFrame(((((1,2,3),(2,3,4)))),(“vals1”,“vals2”])> > >df。選擇(arrays_zip(df。vals1,df。vals2)。別名(“壓縮”))。收集()[行壓縮=[行(vals1 = 1, vals2 = 2)、行(vals1 = 2, vals2 = 3)、行(vals1 = 3, vals2 = 4))))

以前的

pyspark.sql.functions.map_from_entries

下一個

pyspark.sql.functions.map_concat