A streaming application which processes, the Data Expo 2009 Airline On-time Performance data for years from 1987 to 2008 (approximately 120 million records), as streams, applies queries on the streams and shows the resulting visualization for analysis, created using Spark Structured Streaming and Flask.