This project provides an opinionated way to go about crafting Spark Structured Streaming applications with PySpark
Online latent state estimation with Apache Spark.
