snowflake.snowpark.Window¶
- class snowflake.snowpark.Window[source]¶
Bases:
object
Contains functions to form
WindowSpec
. See Snowflake Window functions for reference.Examples:
>>> from snowflake.snowpark.functions import col, avg >>> window1 = Window.partition_by("value").order_by("key").rows_between(Window.CURRENT_ROW, 2) >>> window2 = Window.order_by(col("key").desc()).range_between(Window.UNBOUNDED_PRECEDING, Window.UNBOUNDED_FOLLOWING) >>> df = session.create_dataframe([(1, "1"), (2, "2"), (1, "3"), (2, "4")], schema=["key", "value"]) >>> df.select(avg("value").over(window1).as_("window1"), avg("value").over(window2).as_("window2")).sort("window1").collect() [Row(WINDOW1=1.0, WINDOW2=2.5), Row(WINDOW1=2.0, WINDOW2=2.5), Row(WINDOW1=3.0, WINDOW2=2.5), Row(WINDOW1=4.0, WINDOW2=2.5)]
Methods
orderBy
(*cols)Returns a
WindowSpec
object with order by clause.order_by
(*cols)Returns a
WindowSpec
object with order by clause.partitionBy
(*cols)Returns a
WindowSpec
object with partition by clause.partition_by
(*cols)Returns a
WindowSpec
object with partition by clause.rangeBetween
(start, end)Returns a
WindowSpec
object with the range frame clause.range_between
(start, end)Returns a
WindowSpec
object with the range frame clause.rowsBetween
(start, end)Returns a
WindowSpec
object with the row frame clause.rows_between
(start, end)Returns a
WindowSpec
object with the row frame clause.Attributes
Returns a value representing current row.
Returns a value representing unbounded following.
Returns a value representing unbounded preceding.