With Apache Beam I am trying to create one window which slides over an bounded dataset. The dataset contains, together with other fields like Country, a timestamp field and is sorted on this timestamp.
The goal is to determine, for every event in the dataset, the amount of events to the same country in the last hour.