~/talk

Introduction to Flink in 30 minutes

Talkat Flink Forward Global 2021 · 2021-10-18..10-27· [data-engineering]
links:none on file
slides:none on file

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

  1. 0:00Introduction and use case
  2. 1:20Project requirements
  3. 2:32Apache Flink overview
  4. 3:48Flink architecture and APIs
  5. 5:37Installation and word count
  6. 7:42Job manager and task managers
  7. 9:11Project bootstrapping
  8. 10:17Batch and streaming jobs
  9. 13:22Data enrichment with SQL
  10. 17:01Implementing alerting logic
  11. 20:38Monitoring with Flink UI
  12. 22:05SQL client for analytics
  13. 24:22Conclusion and resources
~/search
type to search 6,249 conferences, 138,987 speakers and 185,172 talks
~/help
cmdctrl k
search every conference, speaker and series
/
focus the filter search
h
home
c
conferences
s
speakers
e
series
t
light / dark — the status bar button does the same
?
this help
esc
close this, then clear every filter — or just the search, while you are typing in it

Ignored while you are typing. Pages without a filter rail have no search to focus.