pyspark.sql.functions.posexplode¶
-
pyspark.sql.functions。posexplode( 上校:ColumnOrName )→pyspark.sql.column.Column¶ -
返回一個新行中每一個元素位置給定數組或地圖。使用默認的列名稱pos的位置,上校數組中的元素關鍵和價值除非另有說明,元素的映射
例子
> > >從pyspark.sql進口行> > >法國電力公司=火花。createDataFrame([行(一個=1,intlist=(1,2,3),mapfield={“一個”:“b”}))> > >法國電力公司。選擇(posexplode(法國電力公司。intlist))。收集()(行(pos = 0,坳= 1)、行(pos = 1,坳= 2),行(pos = 2,坳= 3)]
> > >法國電力公司。選擇(posexplode(法國電力公司。mapfield))。顯示()+ - - - + - - - + - - - +| pos | | |價值的關鍵+ - - - + - - - + - - - +| 0 | | |+ - - - + - - - + - - - +