pyflink.table.window.Session.with_gap

classmethod Session.with_gap(gap: Expression) → SessionWithGap

Creates a session window. The boundary of session windows are defined by intervals of inactivity, i.e., a session window is closes if no event appears for a defined gap period.

Parameters

gap – Specifies how long (as interval of milliseconds) to wait for new data before closing the session window.

Returns

A partially defined session window.