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