pyspark.sql.Column.over

列。 在 ( 窗口:WindowSpec )→列

定义一个窗口列。

参数

窗口 WindowSpec

返回

列

例子

> > >从pyspark.sql进口窗口> > >窗口=窗口。partitionBy(“名称”)。orderBy(“年龄”)。rowsBetween(窗口。unboundedPreceding,窗口。currentRow)> > >从pyspark.sql.functions进口排名,最小值> > >从pyspark.sql.functions进口desc> > >df。withColumn(“排名”,排名()。在(窗口))。withColumn(“最小值”,最小值(“年龄”)。在(窗口))。排序(desc(“年龄”))。显示()+ - - - + - - - + - - - + - - - +岁| | |分钟| |等级名称+ - - - + - - - + - - - + - - - +鲍勃| 5 | | 1 | 5 |爱丽丝| 2 | | 1 | 2 |+ - - - + - - - + - - - + - - - +

以前的

pyspark.sql.Column.otherwise

下一个

pyspark.sql.Column.rlike