How to reduce the number of firings of a Sliding Window in Apache Beam after the max date has been reached?
How can I modify (in Python), the Window set-up in order to eliminate the ‘incomplete’ records which are beyond the max date? Second question is why the window_max_timestamp per window has two weeks difference compared with date_id if window.TimestampedValue is computed from it? I want to be the same.