session_window
function session_window(timeColumn, gapDuration): Column;Defined in: functions/datetime.ts:192
Bucket rows into event-time session windows with a fixed gap.
Returns a struct { start, end } timestamp column. A new session opens
when the gap between consecutive events exceeds gapDuration.
Parameters
Section titled “Parameters”| Parameter | Type | Description |
|---|---|---|
timeColumn |
ColOrName |
event-time column (timestamp) |
gapDuration |
string |
Spark interval string, e.g. "10 minutes" |
Returns
Section titled “Returns”Remarks
Section titled “Remarks”PySpark also accepts a Column gapDuration (dynamic per-row gap).
Only the fixed-string form is supported here; dynamic-gap is a follow-up.