A Practical Introduction to Akka Streams

on YouTube ↗49m

" summary

Live-codes a Scala CSV importer that uses Akka Streams to stream gzipped files, split lines with framing.delimiter, parse lines with futures, batch pairs to compute averages, and write results to Cassandra via async flows. Uses mapAsync and mapAsyncUnordered for controlled parallelism, a Graph DSL balancer to process N files in parallel, and the actor-system materializer to run the graph. It compiles and runs; note inserts scale as concurrentFiles × concurrentWrites, not just one setting.

AI-written summary · about

" chapters (16)

1. 0:00Introduction
2. 4:15Distributed Streams
3. 6:08Example Project
4. 15:50Stream Files
5. 16:40Flatten Sources
6. 20:10ParseLine
7. 21:45MapAsync
8. 23:00Readings
9. 24:40Average
10. 32:50Balancer
11. 42:10Execution Context
12. 43:42Actor System Materializer
13. 44:53Implicit Materializer
14. 47:09Running
15. 48:11Custom flows
16. 48:54Outro

" related talks

• 01h 07mA Practical Introduction to Akka StreamsJacek Kunicki · JDD 2016
• 42mLearn you Akka Streams for great Good!Heiko Seeberger · Scala Days Copenhagen 2017
• 43mReactive Integration with Akka Streams and AlpakkaJacek Kunicki · GeeCON 2019
• 35mPractical Reactive Streams with MonixJacek Kunicki · Scale By The Bay 2018
• 48mA Practical Introduction to Akka StreamsJacek Kunicki · Lambda Days 2017
• 32mPRACTICAL REACTIVE STREAMS WITH MONIXJacek Kunicki · Scalar 2018
• 46mAkka Streams & Reactive Streams in actionKonrad 'ktoso' Malawski · Scala Days Berlin 2016
• 44mPatterns for Streaming Telemetry with Akka StreamsColin Breck · Scala Days Berlin 2018