pyspark.sql.functions.explode_outer¶
-
pyspark.sql.functions。explode_outer( 上校:ColumnOrName )→pyspark.sql.column.Column¶ -
返回一個新行中為每個元素數組或地圖。與爆炸,如果數組/地圖是null或空那麼空。使用默認的列名稱上校數組中的元素關鍵和價值除非另有說明,元素的映射
例子
> > >df=火花。createDataFrame(…((1,(“foo”,“酒吧”),{“x”:1.0}),(2,[],{}),(3,沒有一個,沒有一個)),…(“id”,“an_array”,“a_map”)…)> > >df。選擇(“id”,“an_array”,explode_outer(“a_map”))。顯示()+ - - - + - - - - - - - - - - - - - - - - - - - - - - + + +| | | id an_array | |關鍵值+ - - - + - - - - - - - - - - - - - - - - - - - - - - + + +| 1 | (foo, bar) x 1.0 | | || 2 |[]零零| | |零零零| | | | 3 |+ - - - + - - - - - - - - - - - - - - - - - - - - - - + + +
> > >df。選擇(“id”,“a_map”,explode_outer(“an_array”))。顯示()+ - - - + - - - - - - - - - - - + - - - +| | id a_map | |上校+ - - - + - - - - - - - - - - - + - - - +| 1 | {x - > 1.0} | foo || 1 | {x - > 1.0} | |零| | 2 | {}|零零| | | 3 |+ - - - + - - - - - - - - - - - + - - - +