derived from https://github.com/dataArtisans/infoworld-post
You can fork and clone this repository to run the example applications. All three applications process a stream of taxi ride events that is ingested from a gzipped CSV file, which can be downloaded from Google Drive: