Introduction to Flink in 30 minutes
summary
A working mobile data pipeline is built and demoed: Kafka sources feed Flink in both batch and streaming modes, Flink SQL performs a temporal join (system_time as of) to enrich usage with per-account quotas, then a DataStream process function sums bytes per billing cycle and emits alerts at 90% of quota. State stays local and is snapshotted for recovery (exactly-once state snapshots). The demo processes hundreds of megabytes in about 30 minutes and the code is at https://github.com/alpinegizmo/flink-mobile-data-usage.
AI-written summary · about
chapters (13)
- 0:00Introduction and use case
- 1:20Project requirements
- 2:32Apache Flink overview
- 3:48Flink architecture and APIs
- 5:37Installation and word count
- 7:42Job manager and task managers
- 9:11Project bootstrapping
- 10:17Batch and streaming jobs
- 13:22Data enrichment with SQL
- 17:01Implementing alerting logic
- 20:38Monitoring with Flink UI
- 22:05SQL client for analytics
- 24:22Conclusion and resources
related talks
46mFlink SQL in 2020: Time to show off!
38mApache Flink: A Very Quick Guide
23mBetter, Faster, Stronger Streaming: Your First Dive into Flink SQL
39mBetter, Faster, Stronger Streaming: Your First Dive into Flink SQL
43mA Data Streaming Architecture with Apache Flink #bbuzz
43mLeverage the power and simplicity of SQL on Apache Flink
49mscale.bythebay.io: Stephan Ewen, Apache Flink and the Next Wave of Stream Processing Applications
41mBeyond the Hype: When Apache Flink Solves Real Problems
