Dear Beam users, I am writing a streaming pipeline that has static tables as side inputs. These tables change from time to time and I want the side inputs to be updated at some intervals. I am planning on triggering the update by sending a message through pubsub. When a new message arrives, the side input should be updated. I would like to do this with session windows but on the beam documentation page session windows are depicted as lasting from the first input in the window to the last input in the window and the gap seems to not belong to any window. So if I would use this as a side input how would my main stream be matched to windows? If I send a signal every day and the gap is set to 1 hour, for example, would the window close after 1 hour and for the next 23 hours all the elements in the main stream would be matched to no side input?
Thanks for any help or tips on how to solve this or what is the expected behaviour. BR, Matyas Manninger
