How to create sliding windows in Apache Flink
Apache Flink Sliding windows allow you to aggregate events on partially-overlapping, fixed width time windows. For Flink Sliding windows you need to define:
- The window size: how much time the window will last
- The window slide: what’s the delay between the current window and the next window start time
Find out how you can create sliding windows with Flink SQL.
Check out these resources to learn more:
- Concepts of Aiven for Apache Flink “Application” and “Version” https://www.youtube.com/watch
- Apache Flink Window Types https://www.youtube.com/watch
- Flink windows definition https://nightlies.apache.org/flink/flink-docs-master/docs/dev/datastream/operators/windows/
- Flink SQL Windowing https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/sql/queries/window-agg/
CHAPTERS
00:00 Intro: Apache Flink Sliding Windows Theory
01:28 Check the data in Apache Kafka
01:58 Build an Apache Flink Application
04:04 Define the Apache Flink Sliding window SQL statement
06:33 Check the output data in Apache Kafka
07:34 Summary: How to build Sliding Windows with Apache Flink
Follow Francesco Tisiot on social media:
Twitter: https://twitter.com/FTisiot
LinkedIn: https://www.linkedin.com/in/francescotisiot/
ABOUT AIVEN
Aiven’s cloud data platform helps your business reach its highest potential by making your data work for you.
It provides fully managed open source data infrastructure on all major clouds, helping developers focus on what they do best: innovate and create without worrying about the limitations of technology.
We like to think that Aiven is not only a cloud data platform but also an
extension of your team. We are dedicated to helping you to succeed by removing barriers and finding the right solutions – with the help of the best data technology there is.
CONNECT WITH US
Website: http://aiven.io
LinkedIn: https://linkedin.com/company/aiven
GitHub: https://github.com/aiven
Twitter: https://twitter.com/aiven_io