pyflink.table.window.Session.with_gap#
- classmethod Session.with_gap(gap: pyflink.table.expression.Expression) pyflink.table.window.SessionWithGap [source]#
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.