pyspark.sql.Window¶
-
类
pyspark.sql。窗口¶ -
在DataFrames效用函数定义窗口。
笔记
在订购时没有定义,一个无界的窗框(rowFrame、unboundedPreceding unboundedFollowing)默认情况下使用。定义在订购时,越来越多的窗框(rangeFrame、unboundedPreceding currentRow)默认情况下使用。
例子
> > >#按日期顺序行之间无限前和当前行> > >窗口=窗口。orderBy(“日期”)。rowsBetween(窗口。unboundedPreceding,窗口。currentRow)
> > >#分区由国家秩序前3和3之间的日期范围> > >窗口=窗口。orderBy(“日期”)。partitionBy(“国家”)。rangeBetween(- - - - - -3,3)
方法
orderBy(*峡路)创建一个
WindowSpec定义的命令。partitionBy(*峡路)创建一个
WindowSpec定义的分区。rangeBetween(开始、结束)创建一个
WindowSpec与帧边界定义,开始(包容)结束(包容)。rowsBetween(开始、结束)创建一个
WindowSpec与帧边界定义,开始(包容)结束(包容)。属性