Hello, I am pretty new to Beam and I have a basic question.
Supposing I am ingesting streaming data at a frequency of 1Hz (event time). I need to process them in real time by key, and output results at 1Hz frequency. Time order is extremely important. I need to compute a result which depends on the current PCollectionElement and on the previous one (in event time), per each key. I saw I can use state and timers, but I have the impression that I cannot compute results at the same frequency that input data is produced. Is there a way to ensure time order in this case? Did I misunderstand something? Many thanks in advance, Chiara
