Functions.Window Method

Definition

Namespace:

Microsoft.Spark.Sql

Assembly:

Microsoft.Spark.dll

Package:

Microsoft.Spark v1.0.0

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.Column

Public Shared Function Window (column As Column, windowDuration As String) As Column

Parameters

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

Column object

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.Column

Public Shared Function Window (column As Column, windowDuration As String, slideDuration As String) As Column

Parameters

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

Column object

Remarks

Refer to org.apache.spark.unsafe.types.CalendarInterval for the duration strings.

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.Column

Public Shared Function Window (column As Column, windowDuration As String, slideDuration As String, startTime As String) As Column

Parameters

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

Column object

Remarks

Refer to org.apache.spark.unsafe.types.CalendarInterval for the duration strings.