A Practical Introduction to Akka Streams

on YouTube ↗01h 07m

" summary

Live coding shows a Scala pipeline built with Akka Streams that reads gzipped semicolon‑separated files, frames lines, parses into valid/invalid readings, groups pairs by ID, computes averages (uses -1 when both invalid), and writes results to Cassandra with configurable parallelism for file reads and DB writes. Materialization uses the actor materializer, a resuming logging decider keeps the stream running on errors, the Streams TestKit verifies the flow, and a demo run finishes in under eight seconds.

AI-written summary · about

" chapters (12)

1. 0:00Introduction and setup
2. 3:45What are Akka Streams
3. 10:50Parsing single lines
4. 14:43Splitting files into lines
5. 17:51Parsing files into readings
6. 25:34Computing averages
7. 31:42Storing in Cassandra
8. 36:02Importing single files
9. 40:19Importing directories
10. 45:44Error handling strategy
11. 52:00Testing with Akka Streams
12. 1:03:22Alternatives and resources

" related talks

• 49mA Practical Introduction to Akka StreamsJacek Kunicki · Voxxed Days Vienna 2017
• 46mTame Your Data with Akka StreamsJacek Kunicki · Scale By the Bay 2017
• 42mLearn you Akka Streams for great Good!Heiko Seeberger · Scala Days Copenhagen 2017
• 48mStreaming all the things with Akka StreamsJohan Andrén · Voxxed Days Zurich 2017
• 30mLEARN YOU AKKA STREAMS FOR GREAT GOOD!Heiko Seeberger · Scalar Conference 2017
• 43mReactive Integration with Akka Streams and AlpakkaJacek Kunicki · GeeCON 2019
• 48mA Practical Introduction to Akka StreamsJacek Kunicki · Lambda Days 2017
• 28mStreams on top of ScalaQuentin Adam · Scalar Conference 2015