pyflink.table.window.SessionWithGap.on#
- SessionWithGap.on(time_field: Expression) SessionWithGapOnTime[source]#
Specifies the time attribute on which rows are grouped.
For streaming tables you can specify grouping by a event-time or processing-time attribute.
For batch tables you can specify grouping on a timestamp or long attribute.
- Parameters
time_field – Time attribute for streaming and batch tables.
- Returns
A tumbling window on event-time.