Time series processing requires ordered processing of data points, often across windows boundaries. Tricky stuff for distributed processing systems, in this chat we look at how to solve for these problems using a combination of Global Windows, State and the Timer API’ with Apache Beam.
Using the Timer and State API to solve times series use case in Apache Beam Reza Rokni Kenneth Knowles
September 13, 2019