'Session window gapDuration in Apache beam
I was looking to understand how session window works in apache beam. Let's say I have the following scenario.
- I specify a session window with gapDuration of 4 hours.
- Event 1 with key abc occurs now. A new session is created for this key and this session would last now + 4 hours.
- Event 2 with key abc occurs at now + 3 hours. So it belongs to the same session.
- I have a trigger set up to AfterWatermark.pastEndOfWindow().
Will this trigger occur at now + 4 hours or the session is extended due to the event that occurs at now + 3 hours and hence the trigger occurs at now + 3 + 4 hours?
Sources
This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.
Source: Stack Overflow
| Solution | Source |
|---|