Skip to content
A POC to demonstrate calculating average flight delays using Akka Streams.
Branch: master
Clone or download
Latest commit f8717ad Mar 3, 2016
Permalink
Type Name Latest commit message Commit time
Failed to load latest commit information.
project flight delay streaming poc, initial checkin Jul 5, 2015
src/main/scala/sample/stream
.gitignore flight delay streaming poc, initial checkin Jul 5, 2015
.travis.yml
COPYING flight delay streaming poc, initial checkin Jul 5, 2015
LICENSE flight delay streaming poc, initial checkin Jul 5, 2015
README.md Update README.md Mar 3, 2016
activator flight delay streaming poc, initial checkin Jul 5, 2015
activator-launch-1.2.12.jar flight delay streaming poc, initial checkin Jul 5, 2015
activator.bat flight delay streaming poc, initial checkin Jul 5, 2015
build.sbt Updated to version 2.4.2. Feb 28, 2016

README.md

Flight Delay Streaming

An Akka Streams application that crunches flight data from a CSV file and emits average delays for each airline carrier. Akka Streams will ensure that you're never late for an important business trip again!

Recently updated for Akka 2.4.2.

  1. Convert each line from a String into a FlightEvent
  2. Filter out non-delayed flights from the stream
  3. Broadcast the stream across two distinct flows — one to capture raw events, another to capture aggregate flight delay data
  4. Emit a substream per airline carrier, accumulating the total number of delayed flights and the minutes of each delay for each airline, then merging the streams together with the totals
  5. Print flight delay information to the console

To run this app, you will need to visit http://stat-computing.org/dataexpo/2009/the-data.html and download the CSV file for a single year. This file should be placed in src/main/resources.

You can’t perform that action at this time.