Functions.Window Method
Definition
Important
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
Overloads
| Window(Column, String) |
Generates tumbling time windows given a timestamp specifying column. |
| Window(Column, String, String) |
Bucketize rows into one or more time windows given a timestamp column. |
| Window(Column, String, String, String) |
Bucketize rows into one or more time windows given a timestamp column. |
Window(Column, String)
Generates tumbling time windows given a timestamp specifying column.
public static Microsoft.Spark.Sql.Column Window(Microsoft.Spark.Sql.Column column, string windowDuration);static member Window : Microsoft.Spark.Sql.Column * string -> Microsoft.Spark.Sql.ColumnPublic Shared Function Window (column As Column, windowDuration As String) As ColumnParameters
- column
- Column
The column to use as the timestamp for windowing by time
- windowDuration
- String
A string specifying the width of the window. Refer to org.apache.spark.unsafe.types.CalendarInterval for the duration strings.
Returns
Column object
Applies to
Window(Column, String, String)
Bucketize rows into one or more time windows given a timestamp column.
public static Microsoft.Spark.Sql.Column Window(Microsoft.Spark.Sql.Column column, string windowDuration, string slideDuration);static member Window : Microsoft.Spark.Sql.Column * string * string -> Microsoft.Spark.Sql.ColumnPublic Shared Function Window (column As Column, windowDuration As String, slideDuration As String) As ColumnParameters
- column
- Column
The column to use as the timestamp for windowing by time
- windowDuration
- String
A string specifying the width of the window
- slideDuration
- String
A string specifying the sliding interval of the window
Returns
Column object
Remarks
Refer to org.apache.spark.unsafe.types.CalendarInterval for the duration strings.
Applies to
Window(Column, String, String, String)
Bucketize rows into one or more time windows given a timestamp column.
public static Microsoft.Spark.Sql.Column Window(Microsoft.Spark.Sql.Column column, string windowDuration, string slideDuration, string startTime);static member Window : Microsoft.Spark.Sql.Column * string * string * string -> Microsoft.Spark.Sql.ColumnPublic Shared Function Window (column As Column, windowDuration As String, slideDuration As String, startTime As String) As ColumnParameters
- column
- Column
The column to use as the timestamp for windowing by time
- windowDuration
- String
A string specifying the width of the window
- slideDuration
- String
A string specifying the sliding interval of the window
- startTime
- String
The offset with respect to 1970-01-01 00:00:00 UTC with which to start window intervals
Returns
Column object
Remarks
Refer to org.apache.spark.unsafe.types.CalendarInterval for the duration strings.