Complex Event Processing with Flink: the state of FlinkCEP

on YouTube ↗33m

" summary

An overview of FlinkCEP, a Complex Event Processing library built on Apache Flink that implements pattern matching over event streams for use cases like finance and clickstream analysis. Covers the kinds of CEP patterns supported, the library’s core building blocks and planned extensions, and demonstrates how FlinkCEP leverages Flink features (connectors, event-time processing, exactly-once state, fault-tolerance, savepoints and high throughput).

AI-written summary · about

" chapters (17)

1. 0:00Start
2. 0:35CEP: Complex Event Processing
3. 1:40CEP: use-cases
4. 2:38Distributed Stream Processing
5. 4:10Pattern Definition
6. 5:14FlinkCEP Individual Patterns
7. 8:42FlinkCEP Complex Patterns
8. 9:07FlinkCEP Contiguity Conditions
9. 11:42FlinkCEP Grouping Patterns
10. 13:20FlinkCEP Summary
11. 13:50FlinkCEP Integration with SQL
12. 14:32Running Example: retailer
13. 14:53Observation A Individual Patterns
14. 16:30Running Example Individual Patterns
15. 16:48Running Example Conditions
16. 18:25Documentation
17. 19:35Running Example Pattern Integration

" related talks

• 38mStreaming analytics and CEP ... #bbuzzTill Rohrmann, Fabian Hueske · Berlin Buzzwords 2016
• 39mDeclarative stream processing...Till Rohrmann, Fabian Hueske · Flink Forward Berlin 2016
• 31mBlueprints for common stream processing use cases with FlinkKostas Kloudas · Berlin Buzzwords 2018
• 45mBuilding an Event-Driven Application with Apache FlinkDaniil Tulikov · Joker 2024
• 49mscale.bythebay.io: Stephan Ewen, Apache Flink and the Next Wave of Stream Processing ApplicationsStephan Ewen · Scale By the Bay 2017
• 41mBeyond the Hype: When Apache Flink Solves Real ProblemsNaci Simsek · Berlin Buzzwords 2026
• 38mApache Flink: A Very Quick GuideVladimir Bacvanski · Data By the Bay 2016
• 35mApache Flink 2.0: Unified Enterprise Data Processing System and BeyondBowen Li · Scale By The Bay 2019