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與幀邊界定義,開始(包容)結束(包容)。屬性