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+ - - - + - - - +